来段代码提提神-Java实现SocketServer和client链接

Myth丶恋晨 2022-07-28 00:07 88阅读 0赞

一天的时间很快，要下班了。来段代码提提神，为了我破碎在上海的买房梦；

第一步：写出服务端代码,并启动（启动main函数）：**项目中如何真正的启动服务，读者可以温习下web.xml中的标签，及其作用；此处不表**

import java.net.*;
    import java.io.*;
    
    public class SocketServer {
    	private ServerSocket ss;
    	private Socket socket;
    	private BufferedReader in;
    	private PrintWriter pout;
    
    	
    //	static 
    	public SocketServer() {
    		try {
    			ss = new ServerSocket(1000);
    			while (true) {
    				socket = ss.accept();
    				String RemoteIP = socket.getInetAddress().getHostAddress();
    				String RemotePort = ":" + socket.getLocalPort();
    				System.out.println("A client come in!IP:" + RemoteIP+ RemotePort);
    				in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    				String line = in.readLine();
    				System.out.println("Cleint send is :" + line);
    				//
    				if(line.equals("UU")){
    					line="what is ?";
    					for (int i =1; i < 5; i++) {
    						System.out.println(i-1);
    					}
    				}
    				pout = new PrintWriter(socket.getOutputStream(), true);
    				pout.println("Client input is :"+line);
    				pout.close();
    				in.close();
    				socket.close();
    			}
    		} catch (IOException e) {
    			e.printStackTrace();
    			pout.println("wrong");
    		}
    	}
    
    	public static void main(String[] args) {
    		new SocketServer();
    	}
    }

第二步：写出client端代码

import java.io.*;
    import java.net.*;
    
    public class SocketClient {
    	Socket socket;
    	BufferedReader in;
    	PrintWriter out;
    
    	public SocketClient() {
    		try {
    			System.out.println("Try to Connect to 127.0.0.1:1000");
    			socket = new Socket("127.0.0.1", 1000);
    			socket.setSoTimeout(2*1);
    			System.out.println("The Server Connected!");
    			System.out.println("Please enter some Character:");
    			BufferedReader line = new BufferedReader(new InputStreamReader(System.in));//读取控制台输入
    			out = new PrintWriter(socket.getOutputStream(), true);
    			out.println(line.readLine());
    			in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    			System.out.println("===="+in.readLine());
    			out.close();
    			in.close();
    			socket.close();
    		} catch (IOException e) {
    			out.println("Wrong");
    		}
    	}
    
    	public static void main(String[] args) {
    		new SocketClient();
    	}
    }

客户端启动之后便可和服务端交互；

注意：服务端和客户端，输入流和输出流的顺序关系；