Socket简单入门UDP协议（1）

一、服务器端代码：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketAddress;
import java.net.SocketException;


/**
 * 服务器端
 * */
public class AskServer {
    public static void main(String[] args) {
        try {
            //1.创建接受方(服务器)套接字，并绑定端口号
            DatagramSocket ds=new DatagramSocket(8800);
            //2.确定数据包接受的数据的数组大小
            byte[] buf=new byte[1024];
            //3.创建接受类型的数据包，数据将存储在数组中
            DatagramPacket dp=new DatagramPacket(buf, buf.length);
            //4.通过套接字接受数据
            ds.receive(dp);
            //5.解析发送方发送的数据
            String mess=new String(buf,0,dp.getLength());
            System.out.println("客户端说："+mess);
            //响应客户端
            String reply="您好，我在的，请咨询！";
            byte[] replys=reply.getBytes();
            //响应地址
            SocketAddress sa=dp.getSocketAddress();
            //数据包
            DatagramPacket dp2=new DatagramPacket(replys, replys.length,sa);
            //发送
            ds.send(dp2);
            //6.释放资源
            ds.close();
        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}

二、客户端代码：

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;

/**
 * 客户端
 * */
public class AskClient {
    public static void main(String[] args) {
        //1.确定发送给服务器的信息、服务器地址以及端口
        String mess="你好，我想咨询一个问题！";
        byte[] buf=mess.getBytes();
        InetAddress ia=null;
        try {
            ia=InetAddress.getByName("localhost");
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        int port=8800;
        //2.创建数据包，发送指定长度的信息到指定服务器的指定端口
        DatagramPacket dp=new DatagramPacket(buf, buf.length,ia,port);
        //3.创建DatagramSocket对象
        DatagramSocket ds=null;
        try {
            ds=new DatagramSocket();
        } catch (SocketException e) {
            e.printStackTrace();
        }
        //4.向服务器发送数据包
        try {
            ds.send(dp);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        //接受服务器的响应并打印
        byte[] buf2=new byte[1024];
        //创建接受类型的数据包，数据将存储在数组中
        DatagramPacket dp2=new DatagramPacket(buf2, buf2.length);
        //通过套接字接受数据
        try {
            ds.receive(dp2);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //解析服务器的响应
        String reply=new String(buf2,0,dp2.getLength());
        System.out.println("服务器的响应为："+reply);
        
        //5.释放资源
        ds.close();
    }
}