[javaSE] 网络编程TCP服务端客户端互访阻塞

客户端给服务端发送数据，服务端收到数据后，给客户端反馈数据

 

客户端：

获取Socket对象，new出来，构造参数：String的ip地址，int的端口号

调用Socket对象的getOutputStream()方法，获取到OutputStream对象

调用OutputStream对象的write()方法，输出流输出数据，参数：byte[]字节数组

 

调用Socket对象的getInputStream()方法，获取到InputStream对象

调用InputStream对象的read()方法，读取数据得到读取的长度，参数：byte[]字节数组

获取String对象，new出来，构造参数：byte[]字节数组，0开始，len长度

调用Socket对象的close()方法，关闭socket

 

客户端的输入流读取read()方法，是阻塞式方法，会在这里等待服务端返回数据

 

服务端：

获取ServerSocket对象，new出来，构造参数：int的端口号

调用ServerSocket对象的accept()方法，得到Socket对象

调用Socket对象的getInputStream()方法，得到输入流对象，解析输入流

调用Socket对象的getOutputStream()方法，得到输出流对象，输出数据

调用Socket对象的close()方法，关闭socket

调用ServerSocket对象的close()方法，关闭ServerSocket

 

服务端的accept()方法，是阻塞式方法，会在这里等待客户端的连接

 Server.java

import java.io.InputStream;
 java.io.OutputStream;
 java.net.InetAddress;
 java.net.ServerSocket;
 java.net.Socket;

/**
 * 服务端
 * 
 * @author taoshihan
 * 
 */
public class Server {
    static void main(String[] args) throws Exception {
        ServerSocket serverSocket = new ServerSocket(10004);
//        while (true) {
            Socket socket = serverSocket.accept();
            InputStream inputStream = socket.getInputStream();

            byte[] buf = new byte[1024];
            int len = inputStream.read(buf);

            InetAddress ip = socket.getInetAddress();
            
            System.out.println("来自" + ip.getHostAddress() + "说："
                    + new String(buf,0,len));
            Thread.sleep(10000);睡眠10秒钟，客户端会一直等待
            OutputStream out=socket.getOutputStream();
            out.write("我是服务端，已经收到信息".getBytes());
            
            socket.close();
            serverSocket.close();
        }
    }
}

 java.io.IOException;

 * 客户端
 *  taoshihan
 *
  Client {
     Exception,IOException {
        Socket socket=new Socket(InetAddress.getLocalHost(),10004);
        OutputStream outputStream=socket.getOutputStream();
        outputStream.write("我是客户端，服务端你好".getBytes());
        
        InputStream in=socket.getInputStream();
        byte[] b=];
        int len=in.read(b);这里会阻塞，等待服务端的返回
        System.out.println(new String(b,len));
        socket.close();
    }
}

 

Client.java