UDP實現多線程
UDP實現多線程時，發生了錯誤（while怎么設置停止語句，要不然內存會一直飆升）。誰有編寫好的UDP多線程程序？
小波66
2016-10-04
2 回答
舉報
0/150
提交
取消
2016-11-21
package UDPTest;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
/**
?* 服務器端，實現基于UDP的用戶登錄
?*?
?* @author admin
?*?
?*/
public class UDPService {
public static void main(String[] args) throws IOException {
/*
* 接受客戶端發送的數據
*/
// 創建服務器端DatagramSocket,并指定端口
DatagramSocket socket = new DatagramSocket(8800);
System.out.println("---服務器即將啟動，等待客戶端連接---");
// 創建數據報，用于接受客戶端發送的數據
// 創建字節數組，用于指定接受的數據包的大小
int count = 0;
while (true) {
byte[] data = new byte[1024];
DatagramPacket packet = new DatagramPacket(data, data.length);
// 接受客戶端發送的數據,此方法在接受數據報之前會一直堵塞
socket.receive(packet);
// 創建一個多線程
UDPThread thread = new UDPThread(packet, socket);
// 線程開始
thread.start();
count++;
System.out.println("當前客戶端的數量為：" + count);
// 查看連接的客戶端的地址
System.out.println("當前客戶端的地址為：" + packet.getAddress());
}
}
}
2016-10-04
package com.imooc;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPServerThread extends Thread{
DatagramPacket packet;
DatagramSocket socket;
public UDPServerThread(DatagramPacket packet, DatagramSocket socket) {
super();
this.packet = packet;
this.socket = socket;
}
public void run(){
//讀取數據
byte[] data=packet.getData();
String inf=new String(data,0,packet.getLength());
System.out.println("我是服務器,客戶端說:"+inf);
/*
* 與客戶端響應
*/
InetAddress address=packet.getAddress();
int port =packet.getPort();
byte[] data2="歡迎您".getBytes();
//創建數據報
DatagramPacket packet2=new DatagramPacket(data2, data2.length, address, port);
try {
socket.send(packet2);
} catch (IOException e) {
e.printStackTrace();
}
}
}