Java实现Socket通信-实现客户端和服务端之间通信

桃扇骨 2023-10-19 07:51 293阅读 0赞

用到的知识：  
IO流  
Socket  
先建立好客户端，将要发送的数据转为字符流加载到缓冲区  
Client.java

package com.ifueen.classtest.socket;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.io.OutputStreamWriter;
    import java.io.PrintWriter;
    import java.net.Socket;
    
    public class Client {
    	private Socket sk;
    	public static void main(String[] args) {
    		Client client = new Client();
    		client.connect();
    	}
    	
    	/**
    	 * 创建客户端并连接到服务器
    	 */
    	public void connect() {
    		
    		try {
    			sk = new Socket("localhost",8088);
    			System.out.println("创建客户端成功");
    			//拿到自身的输出流
    			OutputStream outputStream = sk.getOutputStream();
    			//将字节流转换为字符流
    			OutputStreamWriter writer = new OutputStreamWriter(outputStream, "utf-8");
    			//创建缓冲区
    			PrintWriter pw = new PrintWriter(writer,true);
    			pw.println("会沉寂吗");
    			
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    }

然后将服务端搭好：Server.java

package com.ifueen.classtest.socket;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Server {
    	
    	private ServerSocket ss;
    	
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		Server server = new Server();
    		server.connect();
    		server.strat();
    	}
    	
    	/**
    	 * 服务端开启
    	 */
    	public void connect(){
    		try {
    			//创建服务端的端口
    			ss = new ServerSocket(8088);
    			System.out.println("服务端初始化成功");
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    	/**
    	 * 启动监听
    	 */
    	public void strat() {
    		
    		try {
    			//拿到客户端
    			Socket accept = ss.accept();
    			//获取客户端的ip地址
    			String address = accept.getInetAddress().getHostAddress();
    			System.out.println("客户端ip为："+address);
    			
    			//拿到客户端传递的字节流
    			InputStream is = accept.getInputStream();
    			//将字节流转换为字符流
    			InputStreamReader ins = new InputStreamReader(is,"utf-8");
    			//创建输入的缓冲区
    			BufferedReader rd = new BufferedReader(ins);
    			//读取一行
    			String message = rd.readLine();
    			System.out.println(address+":"+message);
    			
    			
    		} catch (IOException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    	
    	
    	
    
    }

先启动服务端，然后再启动客户端，连接好后便可以将客户端的数据发送给服务端了