标签:UDP String int 聊天室 pac 双向 new data ds
利用Sockket和多线程实现的UDP双向聊天室
发送端
public class UdpSend implements Runnable{
private DatagramSocket ds;
private BufferedReader br;
int toPort;
String toID;
UdpServer(int i,String s,int j) throws Exception{
this.toPort = j;
this.toID = s;
ds = new DatagramSocket(i);
br = new BufferedReader(new InputStreamReader(System.in));
}
@Override
public void run() {
while(true) {
String data;
try {
data = br.readLine();
byte[] temp = data.getBytes();
DatagramPacket pac = new DatagramPacket(temp,0,temp.length,
new InetSocketAddress(toID,toPort));
ds.send(pac);
if(data.equals("bye"))break;
} catch (Exception e) {
ds.close();
}
}
ds.close();
}
}
接收端
public class UdpClient implements Runnable{
private DatagramSocket ds;
int naPort;
UdpClient(int i) throws Exception{
this.naPort = i;
ds = new DatagramSocket(naPort);
}
@Override
public void run() {
while(true) {
byte[] data = new byte[1024*60];
DatagramPacket pac = new DatagramPacket(data,0,data.length);
try {
ds.receive(pac);//阻塞式接收
byte[] ndata = pac.getData();
String talk = new String(ndata,0,pac.getLength());
System.out.println(talk);
if(talk.equals("bye"))break;
} catch (Exception e) {
ds.close();
}
}
ds.close();
}
}
调用线程实现双向同时发送信息,双方都说了bye线程关闭。
是不是很简单
标签:UDP,String,int,聊天室,pac,双向,new,data,ds 来源: https://blog.csdn.net/Willy146/article/details/104609972
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。