Java网络编程Socket（使用字节流）

淡淡的烟草味﹌ 2023-09-27 14:37 74阅读 0赞

套接字（Socket）开发网络应用程序被广泛采用，以至于成为事实上的标准。

Socket通信原理：

通信的两端都要有Socket，是两台机器间通信的端点

网络通信其实就是Socket间的通信。

Socket允许程序把网络连接当成一个流，数据在两个Socket间通过IO传输。一般主动发起通信的应用程序属客户端，等待通信请求的为服务端。

当我们需要通讯时（读写数据）

socket.getOutStream();
    socket.getInputStream();

Socket的理解，TCP编程，可靠；UDP编程，不可靠

TCP网络通信编程

编写一个服务端和一个客户端；服务器端在9999端口监听

客户端连接到服务端，发送“hello，server”，然后退出，服务器端接收到客户端发送的信息，输出，并退出。

![f26d2a46eef79d8a9ae6ad4a38dcb57f.png][]

![d6fe47e690326c7d36acc21467281cc5.png][]

![e7bf39e650ce2c0ce3a2f4fb511bd857.png][]

此时情况下的编码：

package com.xjedu.api;
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    /**
     * 客户端,发送“hello ,server”给服务端
     */
    public class SocketTCP01Client {
        public static void main(String[] args)throws IOException {
            //思路：
            //1.连接服务端（ip,端口）
            Socket socket = new Socket(InetAddress.getLocalHost(),9999);
            System.out.println("客户端socket返回=" + socket.getClass());
            //2.连接上后，生成Socket,通过InetAddress.getLocalHost(),9999
            //得到和socket关联的输出流对象
            //Socket.getOutputStream()
            OutputStream outputStream = socket.getOutputStream();
            //3.通过输出流，写入数据到数据通道
            outputStream.write("hello,server".getBytes());
            //4.关闭流对象和socket,必须关闭-----为什么不能直接关闭socket?仅仅关闭socket，流没关闭
            //socket的close方法会判断流是否关闭，只关闭socket就行，socket会自己去关流？
            outputStream.close();
            socket.close();
            System.out.println("客户端退出....");
        }
    }

package com.xjedu.api;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.InetAddress;
    import java.net.ServerSocket;
    import java.net.Socket;
    /**
     * 服务端
     */
    public class SocketTcp01Server {
        public static void main(String[] args) throws IOException {
            //在本机的9999的端口监听，等待连接，但要求9999端口没有被占用
            //这个ServerSocket可以通过accept(),返回多个客户端连接服务器的并发
            ServerSocket serverSocket = new ServerSocket(9999);
            //相当于服务启动了？
            System.out.println("服务端，在9999端口监听，等待连接...");
            //当没有用户端连接9999端口时，程序会阻塞，等待连接,如果有客户端连接，则会返回Socket对象，程序继续
            Socket socket = serverSocket.accept();
            System.out.println("socket = " + socket.getClass());
            //通过socket.getIntputStream()读取客户端写道数据通道的数据，显示
            InputStream inputStream = socket.getInputStream();
            //IO读取
            byte[] buf = new byte[1024];
            int readlen = 0;
            while((readlen = inputStream.read(buf))!= -1){
                System.out.println(new String(buf,0,readlen));
            }
            //关闭数据流
            inputStream.close();
            socket.close();
            serverSocket.close();
        }
    }

在运行程序的时候一定是先运行Server端先跑起来，再运行客户端

![b721d027b965c085ead794ae48f9d743.png][]

![1da67766781c75755591d8272a8e9ee8.png][]

当然这只是单向数据流传输，之前读文件的时候不会出现问题是因为只要读到文件的末尾就会返回read()就会返回-1，但是现在是读socket，没法知道对面是否已经发完了，所以一定要对面调用结束标记，shutdownoutput()发送-1

![fdd2277a931e6fa1885d298a979462aa.png][]

package com.xjedu.api;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    /**
     * 客户端,发送“hello ,server”给服务端
     */
    public class SocketTCP01Client {
        public static void main(String[] args)throws IOException {
            //思路：
            //1.连接服务端（ip,端口）
            Socket socket = new Socket(InetAddress.getLocalHost(),9999);
            System.out.println("客户端socket返回=" + socket.getClass());
            //2.连接上后，生成Socket,通过InetAddress.getLocalHost(),9999
            //得到和socket关联的输出流对象
            //Socket.getOutputStream()
            OutputStream outputStream = socket.getOutputStream();
            //3.通过输出流，写入数据到数据通道
            outputStream.write("hello,server".getBytes());
            //设置一个结束标记
            socket.shutdownOutput();
            //4.获取和socket关联的输出流，取出数据（字节的形式，节点流），并显示
            InputStream inputStream = socket.getInputStream();
            byte[] buf = new byte[1024];
            int readlen = 0;
            while((readlen = inputStream.read(buf))!= -1){
                System.out.println(new String(buf , 0,readlen));
            }
    
            //5.关闭流对象和socket,必须关闭-----为什么不能直接关闭socket?仅仅关闭socket，流没关闭
            //socket的close方法会判断流是否关闭，只关闭socket就行，socket会自己去关流？
            inputStream.close();
            outputStream.close();
            socket.close();
            System.out.println("客户端退出....");
        }
    }

package com.xjedu.api;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.ServerSocket;
    import java.net.Socket;
    /**
     * 服务端
     */
    public class SocketTcp01Server {
        public static void main(String[] args) throws IOException {
            //在本机的9999的端口监听，等待连接，但要求9999端口没有被占用
            //这个ServerSocket可以通过accept(),返回多个客户端连接服务器的并发
            ServerSocket serverSocket = new ServerSocket(9999);
            //相当于服务启动了？
            System.out.println("服务端，在9999端口监听，等待连接...");
            //当没有用户端连接9999端口时，程序会阻塞，等待连接,如果有客户端连接，则会返回Socket对象，程序继续
            Socket socket = serverSocket.accept();
            System.out.println("socket = " + socket.getClass());
            //通过socket.getIntputStream()读取客户端写道数据通道的数据，显示
            InputStream inputStream = socket.getInputStream();
            //IO读取
            byte[] buf = new byte[1024];
            int readlen = 0;
            while((readlen = inputStream.read(buf))!= -1){
                System.out.println(new String(buf,0,readlen));
            }
            //获取socket相关联的输出流
            OutputStream outputStream = socket.getOutputStream();
            outputStream.write("hello,client".getBytes());
            socket.shutdownOutput();
            //关闭数据流
            outputStream.close();
            inputStream.close();
            socket.close();
            serverSocket.close();
        }
    }

![e5833bd08c2ec338f7def09ad4396ef1.png][]

![1d498714df81a7433ac34af321b59d8f.png][]

[f26d2a46eef79d8a9ae6ad4a38dcb57f.png]: https://img-blog.csdnimg.cn/img_convert/f26d2a46eef79d8a9ae6ad4a38dcb57f.png
[d6fe47e690326c7d36acc21467281cc5.png]: https://img-blog.csdnimg.cn/img_convert/d6fe47e690326c7d36acc21467281cc5.png
[e7bf39e650ce2c0ce3a2f4fb511bd857.png]: https://img-blog.csdnimg.cn/img_convert/e7bf39e650ce2c0ce3a2f4fb511bd857.png
[b721d027b965c085ead794ae48f9d743.png]: https://img-blog.csdnimg.cn/img_convert/b721d027b965c085ead794ae48f9d743.png
[1da67766781c75755591d8272a8e9ee8.png]: https://img-blog.csdnimg.cn/img_convert/1da67766781c75755591d8272a8e9ee8.png
[fdd2277a931e6fa1885d298a979462aa.png]: https://img-blog.csdnimg.cn/img_convert/fdd2277a931e6fa1885d298a979462aa.png
[e5833bd08c2ec338f7def09ad4396ef1.png]: https://img-blog.csdnimg.cn/img_convert/e5833bd08c2ec338f7def09ad4396ef1.png
[1d498714df81a7433ac34af321b59d8f.png]: https://img-blog.csdnimg.cn/img_convert/1d498714df81a7433ac34af321b59d8f.png