java聊天小程序

1、import java.awt.color; import java.awt.container; import java.awt.event.actionevent; import java.awt.event.actionlistener; import java.io.bufferedreader; import java.io.inputstreamreader; import java.io.printwriter; import .inet4address; import .inetsocketaddress; import .serversocket; import .socke

2、t; import javax.swing.buttongroup; import javax.swing.jbutton; import javax.swing.jframe; import javax.swing.jlabel; import javax.swing.jpanel; import javax.swing.jradiobutton; import javax.swing.jtextarea; import javax.swing.jtextfield; public class liaot extends jframe implements actionlistener pr

3、ivate static final long serialversionuid = 1l; /按鈕界面上的按鈕private jbutton connect,send,disconnect,save,exit; jradiobutton rb=new jradiobutton2; /聊天區(qū)域private jtextarea ta1; private jtextfield tf1,tf2,tf3; private socket insocket1,socket2; private serversocket socket1; private string inbuf; private buff

4、eredreader in1; private printwriter out1; /服務(wù)器對象private server server; /客戶機對象private client client; public liaot() this.settitle( 聊天 ); container c=getcontentpane(); c.setlayout(null); string s= 服務(wù)器 ,客戶機 ; jradiobutton jrb1=new jradiobutton(*_*) 嘻嘻 ); jradiobutton jrb2=new jradiobutton(+)狂暈 ); jradi

5、obutton jrb3=new jradiobutton( _ )不錯嘛 ); jradiobutton jrb4=new jradiobutton(o(_)o 嗯！ ); jradiobutton jrb5=new jradiobutton(# )汗！ ); jradiobutton jrb6=new jradiobutton(o(_)o 哈哈哈 ); jradiobutton jrb7=new jradiobutton( （*） 哇 ); jradiobutton jrb8=new jradiobutton(o(_)o 嗯！ ); jpanel jp=new jpanel(); jp.s

6、etbackground(color.cyan); jp.setalignmentx(left_alignment); jp.setbounds(380,110, 130, 250); this.add(jp); jp.add(jrb1); jp.add(jrb2); jp.add(jrb3); jp.add(jrb4); jp.add(jrb5); jp.add(jrb6); jp.add(jrb7); jp.add(jrb8); buttongroup bg1=new buttongroup(); for(int i=0;i0); catch (exception e) suppressw

7、arnings( hiding, unused ) class client extends thread suppresswarnings(unused) public client() public void run() try connect.setenabled(false); tf3.settext( 正在等待連接 !); socket2=new socket(); socket2.connect(new inetsocketaddress(tf1.gettext(),21),5000); in1=new bufferedreader(new inputstreamreader(so

8、cket2.getinputstream(); out1=new printwriter(socket2.getoutputstream(),true); while (true) if(socket2.isconnected()=true) tf3.settext( 正在連接 ); send.setenabled(true); disconnect.setenabled(true); break; inbuf=; while(true) inbuf=in1.readline(); if(inbuf.length()0) ta1.append(inbuf); ta1.append(n); ca

9、tch(exception e) public static void main(string args) new liaot(); class server extends thread public server() public void run() try connect.setenabled(false); tf3.settext(正在等待連接。 。 。); tf1.settext(inet4address.getlocalhost().gethostaddress() ); socket1=new serversocket(21); insocket1=socket1.accept(); in1=new bufferedreader(new inputstreamreader(insocket1.getinputstream(); out1=new printwriter(insocket1.getoutputstream(),true