java基础学习网络编程之UDP和TCP协议十四 -3

小灰灰 2024-02-17 19:46 19阅读 0赞

UDP协议传输和接收数据：

SendDemo

package udp01;
    
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;
    import java.net.SocketException;
    
    /**
     * @author Angus
     *	UDP协议发送数据步骤
     *	1：创建发送端Socket对象
     *	2：创建数据并打包
     *	3：发送数据
     *	4：释放资源
     */
    public class SendDemo {
    	public static void main(String[] args)throws Exception {
    
    		//创建socket 对象
    		DatagramSocket ds = new DatagramSocket();
    		
    		//创建数据
    		String str = "hello，UDP发送数据内容";
    		//DatagramPacket 数据包类		
    		byte[] bys = str.getBytes();
    		int len = bys.length;
    		
    		InetAddress address = InetAddress.getByName("192.168.1.160");
    		
    		int port = 12306;
    		
    		DatagramPacket dp = new DatagramPacket(bys, len, address, port);
    		//发送数据 
    		
    		ds.send(dp);
    		
    		//释放资源
    		ds.close();
    	
    	}
    }

ReceiveDemo

package udp01;
    
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;
    import java.net.SocketException;
    
    /**
     * 
     * @author Angus
     *UDP协议接收数据步骤
     *	1：创建接口数据Socket对象
     *	2：创建数据包
     *	3：调用接收方法
     *	4：解析数据
     *	5：释放资源
     *
     *注意：
     *	接收端口和发送端口必须一致
     */
    public class ReceiveDemo {
    	public static void main(String[] args)throws Exception {
    
    		//创建接收对象
    		DatagramSocket ds = new DatagramSocket(12306);
    		
    		//创建数据包
    		byte[] bys = new byte[1024];
    		int len = bys.length;
    		DatagramPacket dp = new DatagramPacket(bys, len);
    		//调用接收方法
    		ds.receive(dp);
    		
    		//解析数据
    		InetAddress address = dp.getAddress();
    		String ip = address.getHostAddress();
    		byte[] bys2 = dp.getData();
    		int length = dp.getLength();
    		String s = new String(bys2,0,length);
    		System.out.println(ip+"----"+s);
    		
    		//释放资源
    		ds.close();
    	
    	}
    }

运行后：

![Center][]

广播地址的概念：

InetAddress address = InetAddress.getByName("192.168.1.255");

最后修改为255后，在这个IP内存的所有用户都可以收到信息。。。。。

同样也可以new两个线程开启这样就不用两个main方法来实现了。。。。

TCP协议传输和接收数据：

ClientDemo：

package tcp01;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    /**
     * @author Angus
     *	TCP协议客户端的步骤
     *	1:创建客户端的Socket对象
     *	2：建立连接
     *	3：获取输出流写数据
     *	4：释放资源
     *
     *Socket：
     *		此类实现客户端套接字（也可以就叫“套接字”）。套接字是两台机器间通信的端点。 
     *	Socket(InetAddress address, int port) 创建一个流套接字并将其连接到指定 IP 地址的指定端口号。
     *	Socket(String host, int port) 创建一个流套接字并将其连接到指定主机上的指定端口号。
     *
     *	运行直接报错：
     *	Exception in thread "main" java.net.ConnectException: Connection refused: connect
     *	所以必须先开服务器，在开客户端，UDP不限制。。。
     */
    public class ClientDemo {
    	public static void main(String[] args) throws Exception {
    		//1:创建客户端的Socket对象和连接
    		//Socket(InetAddress address, int port)
    //		Socket s = new Socket(InetAddress.getByName("192.168.1.160"), 10010);
    		//Socket(String host, int port)
    		Socket s = new Socket("192.168.1.160", 10010);
    		//获取输出流写数据
    		//getOutputStream() 返回此套接字的输出流。
    		OutputStream os = s.getOutputStream();
    		
    		os.write("hello我来了".getBytes());
    		
    		//4：释放资源
    		s.close();
    		
    	}
    }

ServerDemo

package tcp01;
    
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * @author Angus
     *	TCP协议服务端对象
     *	1：创建服务器Socket对象
     *	2;监听连接
     *	3：获取输入流，读取数据
     *	4;释放资源
     *
     *	ServerSocket
     *		此类实现服务器套接字。服务器套接字等待请求通过网络传入。它基于该请求执行某些操作，然后可能向请求者返回结果。 
     *	
     *	public Socket accept() 侦听并接受到此套接字的连接。此方法在连接传入之前一直阻塞。
     */
    public class ServerDemo {
    
    	public static void main(String[] args) throws Exception{
    		//创建对象
    		ServerSocket ss = new ServerSocket(10010);
    		
    		//监听
    		Socket socket = ss.accept();
    		//获取输入流
    		InputStream inputStream = socket.getInputStream();
    		byte[] bys = new byte[1024];
    		int len = inputStream.read(bys);
    		String s = new String(bys,0,len);
    		
    		System.out.println(s);
    		//释放资源
    		inputStream.close();
    //		ss.close();  //服务器一般不关闭，关闭了别人就无法访问了。。
    		
    	}
    
    }

先运行服务器端再运行客户端：

![Center 1][]

[Center]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/30/123812db23ba485aaedb4cf13f9c70f1.png
[Center 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/30/ac68d60a00aa419f9d8e26a6a9cab490.png