1 package com.itheima.demo01.TCP;
 2 
 3 import java.io.IOException;
 4 import java.io.InputStream;
 5 import java.io.OutputStream;
 6 import java.net.Socket;
 7 
 8 /*
 9     TCP通信的客户端:向服务器发送连接请求,给服务器发送数据,读取服务器回写的数据
10     表示客户端的类:
11         java.net.Socket:此类实现客户端套接字(也可以就叫“套接字”)。套接字是两台机器间通信的端点。
12         套接字:包含了IP地址和端口号的网络单位
13 
14     构造方法:
15         Socket(String host, int port) 创建一个流套接字并将其连接到指定主机上的指定端口号。
16         参数:
17             String host:服务器主机的名称/服务器的IP地址
18             int port:服务器的端口号
19 
20     成员方法:
21         OutputStream getOutputStream() 返回此套接字的输出流。
22         InputStream getInputStream() 返回此套接字的输入流。
23         void close() 关闭此套接字。
24 
25     实现步骤:
26         1.创建一个客户端对象Socket,构造方法绑定服务器的IP地址和端口号
27         2.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
28         3.使用网络字节输出流OutputStream对象中的方法write,给服务器发送数据
29         4.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
30         5.使用网络字节输入流InputStream对象中的方法read,读取服务器回写的数据
31         6.释放资源(Socket)
32      注意:
33         1.客户端和服务器端进行交互,必须使用Socket中提供的网络流,不能使用自己创建的流对象
34         2.当我们创建客户端对象Socket的时候,就会去请求服务器和服务器经过3次握手建立连接通路
35             这时如果服务器没有启动,那么就会抛出异常ConnectException: Connection refused: connect
36             如果服务器已经启动,那么就可以进行交互了
37  */
38 public class TCPClient {
39     public static void main(String[] args) throws IOException {
40         //1.创建一个客户端对象Socket,构造方法绑定服务器的IP地址和端口号
41         Socket socket = new Socket("127.0.0.1",8888);
42         //2.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
43         OutputStream os = socket.getOutputStream();
44         //3.使用网络字节输出流OutputStream对象中的方法write,给服务器发送数据
45         os.write("你好服务器".getBytes());
46 
47         //4.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
48         InputStream is = socket.getInputStream();
49 
50         //5.使用网络字节输入流InputStream对象中的方法read,读取服务器回写的数据
51         byte[] bytes = new byte[1024];
52         int len = is.read(bytes);
53         System.out.println(new String(bytes,0,len));
54 
55         //6.释放资源(Socket)
56         socket.close();
57 
58     }
59 
60 }
 1 package com.itheima.demo01.TCP;
 2 
 3 import java.io.IOException;
 4 import java.io.InputStream;
 5 import java.io.OutputStream;
 6 import java.net.ServerSocket;
 7 import java.net.Socket;
 8 
 9 /*
10     TCP通信的服务器端:接收客户端的请求,读取客户端发送的数据,给客户端回写数据
11     表示服务器的类:
12         java.net.ServerSocket:此类实现服务器套接字。
13 
14     构造方法:
15         ServerSocket(int port) 创建绑定到特定端口的服务器套接字。
16 
17     服务器端必须明确一件事情,必须的知道是哪个客户端请求的服务器
18     所以可以使用accept方法获取到请求的客户端对象Socket
19     成员方法:
20         Socket accept() 侦听并接受到此套接字的连接。
21 
22     服务器的实现步骤:
23         1.创建服务器ServerSocket对象和系统要指定的端口号
24         2.使用ServerSocket对象中的方法accept,获取到请求的客户端对象Socket
25         3.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
26         4.使用网络字节输入流InputStream对象中的方法read,读取客户端发送的数据
27         5.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
28         6.使用网络字节输出流OutputStream对象中的方法write,给客户端回写数据
29         7.释放资源(Socket,ServerSocket)
30  */
31 public class TCPServer {
32     public static void main(String[] args) throws IOException {
33         //1.创建服务器ServerSocket对象和系统要指定的端口号
34         ServerSocket server = new ServerSocket(8888);
35         //2.使用ServerSocket对象中的方法accept,获取到请求的客户端对象Socket
36         Socket socket = server.accept();
37         //3.使用Socket对象中的方法getInputStream()获取网络字节输入流InputStream对象
38         InputStream is = socket.getInputStream();
39         //4.使用网络字节输入流InputStream对象中的方法read,读取客户端发送的数据
40         byte[] bytes = new byte[1024];
41         int len = is.read(bytes);
42         System.out.println(new String(bytes,0,len));
43         //5.使用Socket对象中的方法getOutputStream()获取网络字节输出流OutputStream对象
44         OutputStream os = socket.getOutputStream();
45         //6.使用网络字节输出流OutputStream对象中的方法write,给客户端回写数据
46         os.write("收到谢谢".getBytes());
47         //7.释放资源(Socket,ServerSocket)
48         socket.close();
49         server.close();
50     }
51 }

 

版权声明:本文为yhqtv-com原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/yhqtv-com/p/12886267.html