java 多线程实现在线咨询(udp)
程序员文章站
2022-09-17 15:22:21
在线咨询:两个人都可以是发送方,也可以是接收方,实现网上在线咨询正常通信。聊天发送线程package chat;import java.io.bufferedreader;import java.io...
在线咨询:两个人都可以是发送方,也可以是接收方,实现网上在线咨询正常通信。
聊天发送线程
package chat; import java.io.bufferedreader; import java.io.ioexception; import java.io.inputstreamreader; import java.net.datagrampacket; import java.net.datagramsocket; import java.net.inetsocketaddress; import java.net.socketexception; /** * 聊天发送线程: * 重写 run 方法通过 implements 关键字实现 runnable 接口 * 重写方法快捷键:ctrl + o */ public class talksend implements runnable { datagramsocket socket = null; bufferedreader reader = null; private int fromport; //从哪个端口 private string toip; //到哪个地址 private int toport; //到哪个端口 //构造:alt + insert public talksend(int fromport, string toip, int toport) { this.fromport = fromport; this.toip = toip; this.toport = toport; //快捷键:ctrl + alt + t try { //构造一个数据报套接字并将其绑定到本地主机上的指定端口 socket = new datagramsocket(fromport); //准备数据:控制台读取:system.in reader = new bufferedreader(new inputstreamreader(system.in)); } catch (socketexception e) { e.printstacktrace(); } } @override public void run() { while (true){ try { string data = reader.readline(); byte[] databytes = data.getbytes(); datagrampacket packet = new datagrampacket(databytes, 0 , databytes.length, new inetsocketaddress(this.toip, this.toport)); //发送数据包 socket.send(packet); //当发送一句 bye 的时候表示结束发送 if (data.equals("bye")){ break; } } catch (ioexception e) { e.printstacktrace(); } } //关闭 socket.close(); } }
聊天接收线程
package chat; import java.io.ioexception; import java.net.datagrampacket; import java.net.datagramsocket; import java.net.socketexception; /** * 聊天接收线程: * 重写 run 方法通过 implements 关键字实现 runnable 接口 * 重写方法快捷键:ctrl + o */ public class talkreceive implements runnable { datagramsocket socket = null; private int port; private string msgfrom; //构造 public talkreceive(int port, string msgfrom) { this.port = port; this.msgfrom = msgfrom; try { socket = new datagramsocket(port); } catch (socketexception e) { e.printstacktrace(); } } @override public void run() { while (true){ try { //准备接收数据包 byte[] container = new byte[1024]; datagrampacket packet = new datagrampacket(container, 0, container.length); //接收数据包 socket.receive(packet); //阻塞式接收包裹 //读取数据 byte[] data = packet.getdata(); string receivedata = new string(data, 0, data.length); //接收到的数据 system.out.println(msgfrom + ":" + receivedata); //当我们说一声 bye 的时候就表示断开连接 if (receivedata.equals("bye")){ break; } } catch (ioexception e) { e.printstacktrace(); } } //关闭 socket.close(); } }
学生端
package chat; /** * 学生端 */ public class talkstudent { public static void main(string[] args) { /** * 学生端 * 从 7777 端口发送消息 * 发送消息到 9999 端口 * 从 8888 端口接收消息 * * 开启两个线程: * new talksend:从 77777 端口发送,发送到 localhost,发送给 9999 端口 * @param fromport * @param toip * @param toport * * new talkreceive:从 8888 端口接收,接收来自 “老师” 的消息 * @param port * @param msgfrom * * 使用了一种模式:静态代理模式 */ new thread(new talksend(7777, "localhost", 9999)).start(); new thread(new talkreceive(8888, "老师")).start(); } }
老师端
package chat; /** * 老师端 */ public class talkteacher { public static void main(string[] args) { /** * 老师端 * 从 5555 端口发送消息 * 发送消息到 8888 端口 * 从 9999 端口接收消息 * * 开启两个线程: * new talksend:从 5555 端口发送,发送到 localhost,发送给 8888 端口 * @param fromport * @param toip * @param toport * * new talkreceive:从 9999 端口接收,接收来自 “学生” 的消息 * @param port * @param msgfrom * * 使用了一种模式:静态代理模式 */ new thread(new talksend(5555, "localhost", 8888)).start(); new thread(new talkreceive(9999, "学生")).start(); } }
效果一览
以上就是java实现的多线程实现在线咨询(udp)的详细内容,更多关于java 在线咨询的资料请关注其它相关文章!