zoukankan      html  css  js  c++  java
  • Java基础教程——UDP编程

    UDP:User Datagram Protocol,用户数据报协议

    服务端:

    import java.net.*;
    import java.io.*;
    public class UdpServer {
    	public static final int PORT = 30000;
    	// 每个数据报最大为4K
    	private static final int DATA_LEN = 4096;
    	// 接收网络数据的字节数组
    	byte[] buff_in = new byte[DATA_LEN];
    	// 以指定字节数组创建准备接受数据的DatagramPacket对象
    	private DatagramPacket packet_in = new DatagramPacket(buff_in, buff_in.length);
    	// 定义一个用于发送的DatagramPacket对象
    	private DatagramPacket packet_out;
    	public void start() throws IOException {
    		try (
    		// 创建DatagramSocket对象
    		DatagramSocket socket = new DatagramSocket(PORT)) {
    			// 采用循环接受数据
    			while (true) {
    				// 读取Socket中的数据,读到的数据放入inPacket封装的数组里。
    				socket.receive(packet_in);
    				// 判断inPacket.getData()和inBuff是否是同一个数组
    				System.out.println(buff_in == packet_in.getData());
    				// 将接收到的内容转成字符串后输出
    				String _sIn = new String(buff_in, 0, packet_in.getLength());
    				System.out.println("服务器端:" + _sIn);
    				if ("shutdown".equals(_sIn)) {
    					break;
    				}
    				// 从字符串数组中取出一个元素作为发送的数据
    				byte[] sendData = ("服务器收到:" + _sIn).getBytes();
    				// 创建DatagramPacket作为回复
    				SocketAddress addr = packet_in.getSocketAddress();
    				packet_out = new DatagramPacket(sendData, sendData.length, addr);
    				// 发送数据
    				socket.send(packet_out);
    			}
    			System.out.println("=====服务器关闭=====");
    		}
    	}
    	public static void main(String[] args) throws IOException {
    		new UdpServer().start();
    	}
    }
    

    客户端:

    import java.net.*;
    import java.io.*;
    import java.util.*;
    public class UdpClient {
    	// 定义发送数据报的目的地
    	public static final int DEST_PORT = 30000;
    	public static final String DEST_IP = "127.0.0.1";
    	// 定义每个数据报的最大大小为4K
    	private static final int DATA_LEN = 4096;
    	// 定义接收网络数据的字节数组
    	byte[] inBuff = new byte[DATA_LEN];
    	// 创建接受回复数据的DatagramPacket对象
    	private DatagramPacket packet_in = new DatagramPacket(inBuff, inBuff.length);
    	// 定义一个用于发送的DatagramPacket对象
    	private DatagramPacket packet_out = null;
    	public void start() throws IOException {
    		try (DatagramSocket socket = new DatagramSocket()) {
    			// 初始化发送用的DatagramSocket
    			InetAddress ip = InetAddress.getByName(DEST_IP);
    			packet_out = new DatagramPacket(new byte[0], 0, ip, DEST_PORT);
    			// 创建键盘输入流
    			Scanner sc = new Scanner(System.in);
    			System.out.println("请输入数据");
    			// 不断读取键盘输入
    			while (sc.hasNextLine()) {
    				String sUserInput = sc.nextLine();
    				if ("exit".equals(sUserInput)) {
    					break;
    				}
    				// 输入的字符串→字节数组
    				byte[] buff = sUserInput.getBytes();
    				// 设置发送用的DatagramPacket里的字节数据
    				packet_out.setData(buff);
    				// 发送数据报
    				socket.send(packet_out);
    				// 读取Socket中的数据,读到的数据放在inPacket所封装的字节数组里。
    				socket.receive(packet_in);
    				System.out.println(new String(inBuff, 0, packet_in.getLength()));
    				System.out.println("请输入数据:");
    			}
    			System.out.println("===Client ENd===");
    		}
    	}
    	public static void main(String[] args) throws IOException {
    		new UdpClient().start();
    	}
    }
    
  • 相关阅读:
    P2639 [USACO09OCT]Bessie的体重问题Bessie's We…
    P2871 [USACO07DEC]手链Charm Bracelet
    P1983 车站分级
    P1038 神经网络
    P1991 无线通讯网
    P1546 最短网络 Agri-Net
    P1197 [JSOI2008]星球大战
    P1004 方格取数
    P1111 修复公路
    pd_ds 之 hash
  • 原文地址:https://www.cnblogs.com/tigerlion/p/11182823.html
Copyright © 2011-2022 走看看