初识Socket

2024-03-26 16:26:16

Socket类

Socket类实现了客户端套接字，就是两台设备之间通讯端点

构造方法：

        public Socket(String host, int port) :创建套接字对象并将其连接到指定主机上的指定端口号。如果指定的host是null ，
    则相当于指定地址为回送地址。（回送地址(127.x.x.x) 是本机回送地址（Loopback Address），
    主要用于网络软件测试以及本 地机进程间通信，无论什么程序，一旦使用回送地址发送数据，立即返回，不进行任何网络传输。）

参数:

String host:服务器主机的名称/服务器的IP地址
int port:服务器的端口号

成员方法:

	public InputStream getInputStream()：返回此套接字的输入流。如果此Scoket具有相关联的通道，则生成的InputStream 的所有操作也关联该通道。关闭生成的InputStream也将关闭相关的Socket。
	
	 public OutputStream getOutputStream()：返回此套接字的输出流。如果此Scoket具有相关联的通道，则生成的OutputStream 的所有操作也关联该通道。关闭生成的OutputStream也将关闭相关的Socket。
	 
	 public void close()：关闭此套接字。一旦一个socket被关闭，它不可再使用。 关闭此socket也将关闭相关的InputStream和OutputStream 。 
  
      public void shutdownOutput()：禁用此套接字的输出流。 任何先前写出的数据将被发送，随后终止输出流。

注意:

        1.客户端和服务器端进行交互,必须使用Socket中提供的网络流,不能使用自己创建的流对象
        2.当我们创建客户端对象Socket的时候,就会去请求服务器和服务器经过3次握手建立连接通路，这时如果服务器没有启动,那么就会抛出异常ConnectException: Connection refused: connect，如果服务器已经启动,那么就可以进行交互了

代码：

public class TCPClient {
    public static void main(String[] args) throws IOException {
//        1.创建一个客户端对象Socket,构造方法绑定服务器的IP地址和端口号
        Socket socket = new Socket("127.0.0.1", 6666);
//        2.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
        OutputStream os = socket.getOutputStream();
//        3.使用网络字节输出流OutputStream对象中的方法write,给服务器发送数据
        os.write("连接服务器".getBytes());
//        4.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
        InputStream is = socket.getInputStream();
//        5.使用网络字节输入流InputStream对象中的方法read,读取服务器回写的数据
        byte[] bytes = new byte[1024];
        int len = is.read(bytes);
        System.out.println(new String(bytes,0,len));
//        6.释放资源(Socket)
        socket.close();

    }
}

ServerSocket类

ServerSocket 类：这个类实现了服务器套接字，该对象等待通过网络的请求。

构造方法：

      public ServerSocket(int port) ：使用该构造方法在创建ServerSocket对象时，就可以将其绑定到一个指 定的端口号上，参数port就是端口号。

成员方法:

    public Socket accept()：侦听并接受连接，返回一个新的Socket对象，用于和客户端实现通信。该方法会一直阻塞直到建立连接。

服务器的实现步骤:

1.创建服务器ServerSocket对象和系统要指定的端口号
2.使用ServerSocket对象中的方法accept,获取到请求的客户端对象Socket
3.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
4.使用网络字节输入流InputStream对象中的方法read,读取客户端发送的数据
5.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
6.使用网络字节输出流OutputStream对象中的方法write,给客户端回写数据
7.释放资源(Socket,ServerSocket)

代码演示：

public class TCPServer {
    public static void main(String[] args) throws IOException {
//        1.创建服务器ServerSocket对象和系统要指定的端口号
        ServerSocket server = new ServerSocket(6666);
//        2.使用ServerSocket对象中的方法accept,获取到请求的客户端对象Socket
        Socket socket = server.accept();
//        3.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
        InputStream is = socket.getInputStream();
//        4.使用网络字节输入流InputStream对象中的方法read,读取客户端发送的数据
        byte[] bytes = new byte[1024];
        int len = is.read(bytes);
        System.out.println(new String(bytes,0,len));
//        5.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
        OutputStream os = socket.getOutputStream();
//        6.使用网络字节输出流OutputStream对象中的方法write,给客户端回写数据
        os.write("获取到客户端信息".getBytes());
//        7.释放资源(Socket,ServerSocket)
        socket.close();
        server.close();
    }
}

TCP通信分析图解

		1. 服务端启动,创建ServerSocket对象，等待连接。 Socket client = new Socket("127.0.0.1", 6666); 
	     ServerSocket server  = new ServerSocket(6666); 
		2. 客户端启动,创建Socket对象，请求连接。 
		3. 服务端接收连接,调用accept方法，并返回一个Socket对象。 
		4. 客户端Socket对象，获取OutputStream，向服务端写出数据。 
		5. 服务端Scoket对象，获取InputStream，读取客户端发送的数据
		6. 服务端Socket对象，获取OutputStream，向客户端回写数据。 
		7. 客户端Scoket对象，获取InputStream，解析回写数据。 
		8. 客户端释放资源，断开连接。

完成相互通信。在不主动关闭程序的情况下，客户端和服务器端可以一直通信（聊天）。

客户端代码：

public class TCPClient {
    public static void main(String[] args) throws IOException {

//1.创建一个客户端对象Socket,构造方法绑定服务器的IP地址和端口号
   while (true) {
       Socket socket = new Socket("127.0.0.1", 6666);
//        2.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
       OutputStream os = socket.getOutputStream();
//        3.使用网络字节输出流OutputStream对象中的方法write,给服务器发送数据
       Scanner scanner = new Scanner(System.in);
       String s = scanner.nextLine();
       os.write(s.getBytes());
//        4.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
       InputStream is = socket.getInputStream();
//        5.使用网络字节输入流InputStream对象中的方法read,读取服务器回写的数据
       byte[] bytes = new byte[1024];
       int len = is.read(bytes);
       System.out.println(new String(bytes, 0, len));
//
     }
  }
}

服务器端代码：

public class TCPServer {
    public static void main(String[] args) throws IOException {
// 1.创建服务器ServerSocket对象和系统要指定的端口号
        ServerSocket server = new ServerSocket(6666);
//        2.使用ServerSocket对象中的方法accept,获取到请求的客户端对象Socket
        while (true) {
            Socket socket = server.accept();
//        3.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
            InputStream is = socket.getInputStream();
//        4.使用网络字节输入流InputStream对象中的方法read,读取客户端发送的数据
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            System.out.println(new String(bytes, 0, len));
//        5.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
            OutputStream os = socket.getOutputStream();
//        6.使用网络字节输出流OutputStream对象中的方法write,给客户端回写数据
            os.write("获取到客户端信息".getBytes());
//        7.释放资源(Socket,ServerSocket)
        }
    }
}

利用while的死循环将客户端的输入一直重复，因此我们不必要关闭资源。

由于服务器端的回复被写死掉，因此服务器返回给客户端的内容是固定的。

码农公寓

Socket类

相关文章