Java Socket(四)使用UDP传输数据

参考资料: UDP Socket 编程html

package socket;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPSocketClient 
{
	public static void main(String[] args) throws IOException 
	{
		//1.定义服务器的地址、端口、数据
		InetAddress address= InetAddress.getByName("localhost");
		int port = 8800;
		byte[] data = "Hello".getBytes();		
		//2建立数据报
		DatagramPacket packet = new DatagramPacket(data, data.length, address, port);	    
		//3建立DatagramSocket
		DatagramSocket socket = new DatagramSocket();
		//4发送数据
	        socket.send(packet);
		System.out.println("Sended");		
		
		
		/*
		 * 接收服务器端相应的信息
		 */
		//1.建立数据报
		byte[] respdata = new byte[1024];
		DatagramPacket resppacket = new DatagramPacket(respdata, respdata.length);
		//2.接收服务器响应的数据
		socket.receive(resppacket);
		//3.转为字符串
		String reply = new String(respdata, 0, resppacket.getLength());
		System.out.println("received:" + reply);		
		
		
		//关闭资源
		socket.close();
	}
}


package socket;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPSocketServer 
{
	public static void main(String[] args) throws IOException 
	{
		// 1建立服务器端,并指定端口
		DatagramSocket socket = new DatagramSocket(8800);
		// 2建立数据报
		byte[] data = new byte[1024];
		DatagramPacket packet = new DatagramPacket(data, data.length);
		// 3 接收客户端发送的数据
		System.out.println("wait for client...");
		socket.receive(packet);// 此方法在接收到数据以前会一直阻塞
		String info = new String(data, 0, packet.getLength());
		System.out.println("Server side get:" + info);
		
		/*
		 * 向客户端相应
		 */
		//客户端地址、端口、数据
		InetAddress address = packet.getAddress();
	        int port = packet.getPort();
	        byte[] respdata = "Hello,too!".getBytes();
	        //建立数据报,并绑定相应信息
	        DatagramPacket resppacket= new DatagramPacket(respdata, respdata.length,
	    		address, port);
	        socket.send(resppacket);	    
	}
}
相关文章
相关标签/搜索