前言
最近碰到好几个朋友问我，如何实现一个简单的Socket通信。因为好多情况下，还在使用socket通信，来进行数据的传输。比如银行业务。
今天我们就上一个简单的demo。
客户端
闲言碎语不多絮，通信的双方，称为客户端、服务端。
Socket通信，采用的tcp协议，将数据转为流的形式，进行传输。
客户端代码如下：
/** * User: 小隐乐乐 * Date: 2020-08-10 * Time: 10:22 * Description: * Socket通信客户端 */ public class Client { public static void main(String[] args) { Socket socket = null; OutputStream os = null; PrintWriter pw = null; InputStream is = null; InputStreamReader isr = null; BufferedReader br = null; try { socket = new Socket("127.0.0.1", 9090); // 获取输出流向服务端写入数据 os = socket.getOutputStream(); pw = new PrintWriter(os); pw.write("用户名：admin 密码：123"); pw.flush(); socket.shutdownOutput(); // 获取输入流接受服务端返回的信息 is = socket.getInputStream(); isr = new InputStreamReader(is); br = new BufferedReader(isr); String message = null; while ((message = br.readLine()) != null) { System.out.println("服务端说：" + message); } socket.shutdownInput(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } finally { try { if (br != null) { br.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (isr != null) { isr.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (is != null) { is.close(); } } catch (IOException e) { e.printStackTrace(); } if (pw != null) { pw.close(); } try { if (os != null) { os.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (socket != null) { socket.close(); } } catch (IOException e) { e.printStackTrace(); } } } }
非常简单，没有过多装饰的demo代码，提供大家以参考
服务端
服务端，进行接收客户端数据，完成处理后，响应客户端。一般来说，都是保持短连接状态，即，发送 -> 接收 -> 响应 -> 结束。
至于，长连接、短连接的区分，以及如何选择，大家可以自行学习。此处不多做介绍。
服务端代码如下：
/** * User: 薛乐乐 * Date: 2020-08-10 * Time: 10:22 * Description: * 服务端线程类 */ public class ServerSocketThread extends Thread{ private Socket socket; public ServerSocketThread(Socket socket) { this.socket = socket; } @Override public void run() { InputStream is = null; InputStreamReader isr = null; BufferedReader br = null; OutputStream os = null; PrintWriter pw = null; try { // socket获取字节输入流 is = socket.getInputStream(); // 将字节输入流转字符输入流 isr = new InputStreamReader(is); // 将字符输入流转行输入流 br = new BufferedReader(isr); // String message = null; while ((message = br.readLine()) != null) { System.out.println("客户端发来消息：" + message); } // 必须先关闭输入流才能获取下面的输出流 socket.shutdownInput(); // 获取输出流 os = socket.getOutputStream(); pw = new PrintWriter(os); pw.write("欢迎您进入socket"); pw.flush(); // 关闭输入流 socket.shutdownOutput(); } catch (Exception e) { e.printStackTrace(); } finally { // 关闭资源 if (pw != null) { pw.close(); } try { if (br != null) { br.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (isr != null) { isr.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (os != null) { os.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (br != null) { br.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (isr != null) { isr.close(); } } catch (IOException e) { e.printStackTrace(); } try { if (is != null) { is.close(); } } catch (IOException e) { e.printStackTrace(); } } } } /** * User: 薛乐乐 * Date: 2020-08-10 * Time: 10:22 * Description: * Socket通信服务端 * 1：建立服务端监听socket * 2：等待接受连接请求 * 3：接受请求后建立socket连接 * 4：输入、输出流 * 5：关闭socket以及相关资源 */ public class Server { private static ServerSocket SERVER_SOCKET =null;; static{ try { SERVER_SOCKET = new ServerSocket(9090); } catch (IOException e) { e.printStackTrace(); } } public static void main(String[] args) { try { System.out.println("******服务器已启动，等待客户端连接*****"); Socket socket = null; while(true){ //循环监听客户端的连接 socket = SERVER_SOCKET.accept(); //新建一个线程ServerSocket，并开启 new ServerSocketThread(socket).start(); } } catch (IOException e) { e.printStackTrace(); } } }
服务端，循环监听客户端的连接，进行数据交互。
demo奉上，希望大家能够理解。更多的，原理内容，可以回顾java 核心的通信篇。
