原文链接:https://www.cnblogs.com/hysum/p/7531529.html
Socket通信 :
- TCP协议是面向对象连接、可靠的、有序的,以字节流的方式发送数据。
- 基于TCP协议实现网络通信的类:
- 客户端----Socket类
- 服务器端----ServerSocket类
一、Socket通信模型
(1) 在服务端建立一个ServerSocket,绑定相应的端口,并且在指定的端口进行侦听,等待客户端的连接。
(2) 当客户端创建连接Socket并且向服务端发送请求。
(3) 服务器收到请求,并且接受客户端的请求信息。一旦接收到客户端的连接请求后,会创建一个链接socket,用来与客户端的socket进行通信。 通过相应的输入/输出流进行数据的交换,数据的发送接收以及数据的响应等等。
(4) 当客户端和服务端通信完毕后,需要分别关闭socket,结束通信。
Socket通信实现步骤:
(1) 创建ServerSocket和Socket
(2) 打开链接到Socket的输入/输出流
(3) 按照协议对Socket进行读/写操作
(4) 关闭输入输出流、关闭Socket
二、Socket和ServerSocket常用方法
ServerSocket常用方法:
- ServerSocket(int port)——创建并绑定到特定端口的服务器套接字
- accept()——侦听并接受到此套接字的连接
- close()——关闭此套接字 getInetAddress()——得到ServerSocket对象绑定的IP地址。如果ServerSocket对象未绑定IP地址,返回0.0.0.0。
- getLocalPort()——返回此套接字在其上侦听的端口
Socket常用方法:
- Socket(InetAddress address, int port)——创建一个套接字并将其连接到指定ip地址的指定端口号
- Socket(String host, int port)——创建一个套接字并将其连接到指定主机上的指定端口号
- close()——关闭此套接字
- getInetAddress()——返回套接字连接的地址
- getInputStream()——返回此套接字的输入流
- getOutputStream——返回此套接字的输出流
三、编程实现基于TCP/IP的用户登录小程序
1. 服务端
- 创建ServerSocket对象,绑定监听端口
- 通过accept()方法监听客户端请求
- 连接建立后,通过输入流读取客户端发送的请求信息
- 通过输出流向客户端发送响应信息
- 关闭相关资源
public class TcpServer { public static void main(String[] args) throws IOException{ // 1.创建一个服务器端的Socket,即ServerSocket,指定绑定的端口 ServerSocket ss = new ServerSocket(8888); // 2.调用accept方法开始监听,等待客户端的连接 System.out.println("服务器即将启动,等待客户端的连接..."); Socket so = ss.accept();// accept方法返回Socket实例 // 3.获取一个输入流,并读取客户端信息 InputStream is = so.getInputStream();// 字节输入流 InputStreamReader isr = new InputStreamReader(is);// 将字节输入流包装成字符输入流 BufferedReader br = new BufferedReader(isr);// 加上缓冲流,提高效率 String info = null; while ((info = br.readLine()) != null) {// 循环读取客户端信息 System.out.println("我是服务器,客户端说:" + info); } so.shutdownInput();// 关闭输入流 // 4.获取一个输出流,向客户端输出信息,响应客户端的请求 OutputStream os = so.getOutputStream();// 字节输出流 PrintWriter pw = new PrintWriter(os);// 字符输出流 BufferedWriter bw = new BufferedWriter(pw);// 缓冲输出流 bw.write("欢迎您!"); bw.newLine(); bw.flush(); // 5.关闭资源 os.close(); pw.close(); bw.close(); br.close(); isr.close(); is.close(); so.close(); ss.close(); } }