package pers.Sockets;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.Socket;
// UDP服务器线程处理累
public class UDPServerThread extends Thread {
DatagramPacket packet=null;
DatagramSocket socket=null;
byte[] data=null;
public UDPServerThread(DatagramPacket packet,DatagramSocket socket,byte[] data){
this.packet=packet;
this.socket=socket;
this.data=data;
}
//线程执行操作,响应客户端的请求
public void run(){
try {
DatagramPacket packet2=new DatagramPacket("欢迎您!".getBytes(), "欢迎您!".getBytes().length, packet.getAddress(),packet.getPort());;
//4.读取数据
String info=new String(data,0,packet.getLength());
System.out.println("我是服务器,客户端说:"+info);
///**** 向客户端做出响应没有实现,仍存在问题 ****/
/*
* 向客户端做出响应
*/
//2.创建数据报、包含响应的数据信息
/* packet2 */
//3.响应客户端
System.out.println("已响应客户端!"+UDPServerT.count);
socket.send(packet2);
// //4.关闭资源
// socket.close();
} catch (IOException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
}
}
}