java之socket编程

深藏阁楼爱情的钟 2021-12-20 23:41 237阅读 0赞

服务端代码：

import java.net.*;
    import java.io.*;
    
    public class TCPServer3 {
    	
    	private ServerSocket MyListener;
    	public static final int port = 1024;
    	private Socket LinkSocket;
    	public TCPServer3() {
    		try {
    			//创建服务端套接字
    			MyListener = new ServerSocket(port);	
    		}
    		catch(IOException e) {
    			e.printStackTrace();
    		}
    	}
    	public void setConnection(){
    		//监听连接请求
    	
    		try {
    			while(true) {
    				LinkSocket = MyListener.accept();
    				System.out.println("Client is come！");
    				ReadData();
    			}	
    		}
    		catch(IOException e) {
    			e.printStackTrace();
    		}
    	}
    	public void ReadData(){
    		try {
    			DataInputStream dis = new DataInputStream(LinkSocket.getInputStream());
    			System.out.println(dis.readUTF());
    			dis.close();
    		}
    		catch(IOException e) {
    			e.printStackTrace();
    		}
    
    	}
    	
    	public static void main(String args[]) throws Exception {
    		TCPServer3 MyServer = new TCPServer3();
    		MyServer.setConnection();
    		MyServer.LinkSocket.close();	
    	}
    	
    }

客户端代码：

import java.net.*;
    import java.io.*;
    
    public class TCPClient3 {
    	private static final String IP = "192.168.237.1";
    	private static final int port = 1024;
    	Socket ClientSocket;
    	
    	public TCPClient3() {
    		try {
    			ClientSocket = new Socket(IP,port);
    		}
    		catch(IOException e) {
    			e.printStackTrace();
    		}
    	}
    	public void setConnection() {
    		try {
    			Socket ClientSocket = new Socket(IP,port);
    		}
    		catch(IOException e) {
    			e.printStackTrace();
    		}
    	}
    	public void SendData() {
    		try {
    			OutputStream os = ClientSocket.getOutputStream();
    			DataOutputStream dos = new DataOutputStream(os);
    			dos.writeUTF("hello server!");
    			dos.flush();
    			dos.close();
    		}
    		catch(IOException e) {
    			e.printStackTrace();
    		}
    
    	}
    	
    	public static void main(String args[]) throws Exception {
    		TCPClient3 MyClient = new TCPClient3();
    		//申请连接
    		MyClient.setConnection();
    		//发送数据
    		MyClient.SendData();
    		//关闭连接
    		MyClient.ClientSocket.close();
    	}
    	
    }

程序只支持单线程，有待改进。