UDP无连接的Socket通信

红太狼 2022-07-11 08:20 155阅读 0赞

1.服务器端

import java.io.IOException;
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;
    
    /*
     * UDP 无连接的Socket通信
     * 
     *     服务器端
     */
    public class UDPServer {
    	public static void main(String[] args) {
    		UDPServer frm=new UDPServer();
    	}
    	SerThread st;                        //声明服务器类线程对象st
    	public UDPServer(){
    		st=new SerThread();              //创造线程
    		st.start();                      //启动线程
    	}
    }
    
    class SerThread extends Thread{           //服务器类线程，负责接收信息
    	
    	public SerThread(){}                  //构造方法
    	
    	public void run(){
    		String str1;
    		try{
    			//使用8000端口，建立UDP Socket对象
    			DatagramSocket skt=new DatagramSocket(8000);
    			System.out.print("服务器名：");
    			//显示服务器计算机的名称
    			System.out.println(InetAddress.getLocalHost().getHostName());
    			while(true){
    				byte[] inBuf=new byte[256];
    			    //下面是取得服务器端地址
    				DatagramPacket pkt;
    				//创建并设置接收pkt对象的接收信息
    				pkt=new DatagramPacket(inBuf, inBuf.length);
    				skt.receive(pkt);                   //接收数据报分组
    				str1=new String(pkt.getData());
    				str1=str1.trim();                    //去掉字符串的首尾空格
    				if(str1.length()>0){
    					int pot=pkt.getPort();           //获取远程口号
    					System.out.println("远程端口："+pot);
    					System.out.println("服务器已接收到信息："+str1);
    				}
    			}
    		} catch(IOException e){
    			return;
    		}
    	}
    }

2.客户端

import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;
    
    /*
     *UDP 无连接的Socket通信
     *
     *    客户端
     */
    public class UDPClient {
    	public static void main(String[] args) {
    		UDPClient frm=new UDPClient();
    	}
    	CliThread ct;                   //声明客户类线程对象ct
    	
    	public UDPClient(){             //构造方法
    		ct=new CliThread();         //创建线程
    		ct.start();                 //启动线程
    	}
    }
    
    class CliThread extends Thread{     //客户端线程类，负责发送信息
    	public CliThread(){}
    	
    	public void run(){                 
    		String str1;
    		String serverName="Nightliar-PC";                //服务器计算机名
    		System.out.println("请发送信息给服务器《"+serverName+"》");
    		try{
    			DatagramSocket skt=new DatagramSocket();          //建立UDP socket对象
    			DatagramPacket pkt;                               //建立 DatagramSocket对象pkt
    			while(true){ 
    				BufferedReader buf;
    				buf=new BufferedReader(new InputStreamReader(System.in));
    				System.out.println("请输入信息");
    				str1=buf.readLine();                          //从键盘上读取数据
    				byte[] outBuf=new byte[str1.length()];
    				outBuf=str1.getBytes();
    				//下面是取得服务器端地址
    				InetAddress address=InetAddress.getByName(serverName);
    				pkt=new DatagramPacket(outBuf, outBuf.length,address,8000);        //数据打包
    				skt.send(pkt);                                  //发送UDP数据报分组
    			}
    		} catch(IOException e){
    			e.printStackTrace();
    		}
    	}
    }