本文为大家分享了 java 实现简单 聊天软件 的具体代码，供大家参考，具体内容如下
介绍
这是我自己学习socket时写的，用到了多线程，socket的知识，还有java的io技术，并且做了一个java的ui，废话不多说，先上效果图
sendthread
这个类是用来实现数据的发送的，当按键按下时，会调用 sendmessage 方法
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 |
public class sendthread {
chatwindow chatwindow; private string remoteip = "" ; private int port = 0 ; private string message = "" ;
public sendthread( int port,chatwindow window) { chatwindow = window; }
public void notrun() { inetsocketaddress isa = new inetsocketaddress(remoteip, port); try { socket socket = new socket(); socket.connect(isa); outputstreamwriter writer = new outputstreamwriter(socket.getoutputstream()); writer.write(message); writer.flush(); writer.close(); system.out.println( "将数据写入到流中" ); } catch (ioexception e) { e.printstacktrace(); } finally { message = "" ; } }
public void senmessage(string host, int port,string message){ remoteip = host; this .port = port; this .message = message; notrun(); }
} |
receivethread
这个类实现的功能是维护一个阻塞线程，来对端口进行监听，接受收到的信息，每当收到信息时，都会显示。
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
public class receivethread extends thread {
private serversocket server; private chatwindow window;
public receivethread(chatwindow window) { this .window = window; try { server = new serversocket( 0 ); window.setlocalport(server.getlocalport()); start(); } catch (ioexception e) { // todo auto-generated catch block window.printerror( "连接出错" ); } }
@override public void run() { // todo auto-generated method stub while ( true ){ socket socket; try { socket = server.accept(); inputstreamreader reader = new inputstreamreader(socket.getinputstream()); int c; stringbuilder sb = new stringbuilder(); while ((c = reader.read()) != - 1 ){ sb.append(( char )c); } window.setreceive(sb.tostring()); } catch (ioexception e) { // todo auto-generated catch block system.out.println( "线程将接受到的数据写入对话框出错" ); } } } } |
chatwindow
这个类是ui的实现，通过绑定各个按钮的操作来实现别的功能
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 |
public class chatwindow extends jframe {
private jbutton sendbutton; private jbutton cancelbutton; private jbutton receivebutton; private jtextarea receivetext; private jtextfield sendtext;
private jlabel localport;
private jtextfield remoteaddress; private jtextfield remoteport; private sendthread sendthread; private receivethread receivethread;
private void guiini(){ container c = this .getcontentpane(); c.setlayout( new borderlayout()); setsize( 400 , 500 );
//第一个panel jpanel panel1 = new jpanel( new gridlayout( 4 , 2 )); // jpanel panel1 = new jpanel(new (4, 2)); panel1.setsize( 400 , 75 ); panel1.add( new jlabel( "当前机器的ip地址是:" )); try { panel1.add( new jlabel(inetaddress.getlocalhost().gethostaddress())); } catch (unknownhostexception e) { // todo auto-generated catch block panel1.add( new jlabel( "当前机器的ip地址是:" + "unknown" )); } panel1.add( new jlabel( "当前对话的端口是:" )); panel1.add(localport = new jlabel( "" + 0 )); panel1.add( new jlabel( "remote host ip address:" )); remoteaddress = new jtextfield(); remoteaddress.setcolumns( 0 ); panel1.add(remoteaddress); panel1.add( new jlabel( "remote host port:" )); remoteport = new jtextfield(); remoteport.setcolumns( 0 ); panel1.add(remoteport); c.add(panel1,borderlayout.north);
//第二个panel jpanel panel2 = new jpanel( new flowlayout(flowlayout.leading)); panel2.setsize( 400 , 200 ); panel2.add( new jlabel( "收到的内容" )); receivetext = new jtextarea( 15 , 30 ); receivetext.seteditable( false ); receivetext.setautoscrolls( true ); jscrollpane jsp = new jscrollpane(receivetext); panel2.add(jsp); //第三个panel // jpanel panel3 = new jpanel(new gridlayout(2, 1)); panel2.add( new jlabel( "请输入发送的内容" )); sendtext = new jtextfield( 30 ); sendtext.setautoscrolls( true ); panel2.add(sendtext); c.add(panel2,borderlayout.center); //c.add(panel3); //第四个panel jpanel panel4 = new jpanel( new gridlayout( 1 , 0 )); panel4.setsize( 400 , 20 ); receivebutton = new jbutton( "开始接受数据" ); sendbutton = new jbutton( "发送" ); cancelbutton = new jbutton( "取消" ); panel4.add(receivebutton); panel4.add(cancelbutton); panel4.add(sendbutton); c.add(panel4,borderlayout.south); //四个面板内容设置完毕
setvisible( true ); setresizable( false ); setdefaultcloseoperation(exit_on_close); }
private void actionini() {
//键盘动作 this .addkeylistener( new keylistener() {
@override public void keytyped(keyevent e) {
}
@override public void keyreleased(keyevent e) { // todo auto-generated method stub if (e.getkeycode() == keyevent.vk_enter){ //发送文本 sendthread.senmessage(remoteaddress.gettext(), integer.parseint(remoteport.gettext()), sendtext.gettext()); receivetext.settext(receivetext.gettext() + "\n" + "发送:" + sendtext.gettext()); } }
@override public void keypressed(keyevent e) { // todo auto-generated method stub
} }); //取消按钮的动作 cancelbutton.addmouselistener( new mouselistener() {
@override public void mousereleased(mouseevent e) { // todo auto-generated method stub sendtext.settext( "" ); }
@override public void mousepressed(mouseevent e) { // todo auto-generated method stub
}
@override public void mouseexited(mouseevent e) { // todo auto-generated method stub
}
@override public void mouseentered(mouseevent e) { // todo auto-generated method stub
}
@override public void mouseclicked(mouseevent e) { // todo auto-generated method stub
} }); sendbutton.addmouselistener( new mouselistener() {
@override public void mousereleased(mouseevent e) { //发送文本 sendthread.senmessage(remoteaddress.gettext(), integer.parseint(remoteport.gettext()), sendtext.gettext()); receivetext.settext(receivetext.gettext() + "发送:" + sendtext.gettext()+ "\n" ); }
@override public void mousepressed(mouseevent e) { // todo auto-generated method stub
}
@override public void mouseexited(mouseevent e) { // todo auto-generated method stub
}
@override public void mouseentered(mouseevent e) { // todo auto-generated method stub
}
@override public void mouseclicked(mouseevent e) { // todo auto-generated method stub
} }); }
private void threadini() { // todo auto-generated method stub sendthread = new sendthread( 0 , this ); receivethread = new receivethread( this ); } //构造函数 public chatwindow() { guiini(); actionini(); threadini(); }
public void printerror(string err){ system.out.println( "error occur:" + err); }
//回调函数,用于接受从线程中返回的数据 public void setreceive(string receive){ receivetext.settext(receivetext.gettext() + "收到:" + receive+ "\n" ); }
//当接受数据的线程开始工作以后，就调用该回调函数，设置当前聊天窗口使用的端口是哪个 public void setlocalport( int localporttext){ localport.settext( "" +localporttext); }
//放远，这个是整个程序的起点 public static void main(string[] args) { // todo auto-generated method stub new chatwindow(); }
} |
如何使用
将工程导入到eclipse中以后，运行两次，因为这个程序不属于单例模式，所以可以出现两个窗口，在远程端口，远程地址那个输入框中分别输入另一个窗口中显示的ip和端口号，接下来在输入框中输入要发送的文字就可以了
源码下载： java实现简单聊天软件
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
原文链接：https://blog.csdn.net/im_zhq/article/details/51393012