Java网络编程---Socket

我会带着你远行 2022-03-11 07:42 318阅读 0赞

好久没有写博客了，有朋友跟我说，跟我聊聊Java的Socket编程吧，虽然知道是那么回事，但是有的时候有好像不太清晰，所以按照我自己的理解写一下，了解我的朋友都知道，我只会介绍怎么入门，至于深入，边用边研究是最好的。

废话不多说，要想知道一件事情的本质，就要了解事情的真相。

1.Socket通讯的本身是基于TCP协议编程，所以协议我们要清楚，三次握手原则要大概理解它的意思。

2.还要理解Java的IO读写知识，也就是输入输出流的知识，因为通讯的过程是关于流的

3.接下来就是要理解Socket编程本身的知识（查看API），Socket有客户端、有服务端。

4.怎么创建Socket客户端、怎么创建SocketServer服务端

5.客户端跟服务端之间的通讯

6.注意一些细节方面的知识，比如保证连接，支持重新连接啊、心跳信息

下面通过一个例子来看下：Socket客户端

import java.io.IOException;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.util.Date;
    
    /**
     * describe:
     *
     * @author ynsmile
     * @version 1.0
     * @since 2019-02-15 14:05
     **/
    public class SocketClient {
    
        private static String host = "127.0.0.1";
        private static int port = 1234;
        private Socket socket;
        private static SocketClient socketClient = null;
    
        private SocketClient(){
            init();
        }
    
        public synchronized static SocketClient getSocketClient(){
                if(socketClient == null){
                    socketClient = new SocketClient();
                }
           return socketClient;
        }
    
        private void init(){
            //或者在这里判断是否连接
            if (this.socket == null){
                try {
                    this.socket = new Socket(host,port);
                } catch (IOException e) {
                    System.out.println("socket init fail");
                }
            }
        }
    
        public void send(String msg){
            try {
                //可以先检查是否已经连接，再写一个方法isConnect()
                //但是本身TCP连接就是可靠的，我觉得没必要，如果没有连接必然是会抛出异常的
                OutputStream outputStream = socket.getOutputStream();
                outputStream.write(msg.getBytes("UTF-8"));
                outputStream.flush();
            } catch (IOException e) {
                try {
                    Socket socket = new Socket(host,port);
                    OutputStream outputStream = socket.getOutputStream();
                    outputStream.write(msg.getBytes("UTF-8"));
                    outputStream.close();
                    socket.close();
                } catch (IOException e1) {
                    System.out.println("Socket重新连接失败...");
                }
            }
        }
    
    }

接着便是服务端了

import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * describe:
     *
     * @author chibingyang
     * @version 1.0
     * @since 2019-02-15 14:01
     **/
    public class SocketServer {
    
        public static void main(String[] args) throws IOException {
            // 监听指定的端口
            int port = 1234;
            ServerSocket server = new ServerSocket(port);
            System.out.println("我是姜太公，一直在等鱼儿上钩。。。");
            while(true){
                Socket socket = server.accept();
                // 建立好连接后，从socket中获取输入流，并建立缓冲区进行读取
                InputStream inputStream = socket.getInputStream();
                byte[] bytes = new byte[1024];
                int len;
                StringBuilder sb = new StringBuilder();
                while ((len = inputStream.read(bytes)) != -1) {
                    sb.append(new String(bytes, 0, len, "UTF-8"));
                }
                System.out.println("鱼儿上钩了: " + sb);
                inputStream.close();
                socket.close();
            }
    
        }
    }

这里需要特别注意的是不过是socket主动关闭，还是流的关闭都会导致断开连接，切记！

好了，上面就是Socket编程的大概了，也是Java TCP编程的部分。后面再介绍UDP怎么连接。如果有错，欢迎指正