使用java如何实现基于TCP协议网络socket编程
发布时间：2020-10-31 01:23:16
来源：亿速云
阅读：118
作者：Leah
使用java如何实现基于TCP协议网络socket编程？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
一、前言：TCP原理简介
首先，保证文章完整性，TCP的理论原理还是需要简介一下，略显枯燥?乛?乛?。
TCP(传输控制协议，Transmission Control Protocol)是一种面向连接的、可靠的、基于字节流的传输层通信协议。TCP旨在适应支持多网络应用的分层协议层次结构。也就是说，TCP是为了在不可靠的互联网络上提供可靠的端到端字节流而专门设计的一个传输协议。 连接到不同但互连的计算机通信网络的主计算机中的成对进程之间依靠TCP提供可靠的通信服务。
以上TCP的特点，也正是与UDP的明显不同之处。UDP(用户数据报协议)是一种无连接的、不可靠的、不以字节流传输通信协议。具体区别可对比之前这篇文章：
【基于UDP协议网络Socket编程(java实现C/S通信案例) 】 [https://www.jb51.net/article/198498.htm]
接着，“三次握手”则是众所周知的一个词，是建立TCP连接的重要过程。许多文章有详细解读，本篇则是详细记录在此原理之上，使用Java实现TCP的Socket网络通信，包含C/S软件架构的程序设计，偏向实践，更加有趣！
文章图片
二、Socket编程通信
本篇使用Java进行Socket编程，Java的TCP/IP套接字编程将底层的细节进行了封装，其编程模型如图：
文章图片
我们自顶向下观察，基于TCP的通信，必然有服务端Server和客户端Client。
首先，建立连接。两端分别有一个套接字Socket，用于两者之间的通信。客户端向服务器发送请求，创建socket进行连接。服务端则随时监听客户端发起的请求，接收并创建裂解Socket。
其次，开始通信。服务和客户两端的输入输出流互相通信。逻辑上可理解为通信进程的双方具有两个流(输出流和输入流)。逻辑上可将两个流理解为两个通信管道的全双工通信模式，一个用于向对方发送数据，另一个用于接收对方的数据。
最后，结束通信。客户端访问服务器结束，断开连接，关闭Socket和相关资源(输入输出流等)。服务端监听客户端状态，同时关闭Socket等连接。
建立通信规则：
Server和Client之间需要约定相同的规则，保证正常通信。之后的程序设计，我们约定：
客户端连接服务器，连接成功后，服务器首先给客户端发送一条欢迎信息；
客户端程序每发送一条信息给服务器，服务器接收并回送该信息到客户端，客户端接收并显示该信息；
当客户端发送"bye"，则结束对话。
三、TCP服务器端(具体代码)
第一步，创建服务端套接字。
类成员变量：ServerSocket serverSocket，监听端口号port；
private int port =8008;
//服务器监听窗口
private ServerSocket serverSocket;
//定义服务器套接字
public TCPServer() throws IOException{
serverSocket =new ServerSocket(port);
System.out.println("服务器启动监听在"+port+"端口...");
}
第二步，定义输入输出流方法：
private PrintWriter getWriter(Socket socket) throws IOException{
//获得输出流缓冲区的地址
OutputStream socketOut=socket.getOutputStream();
//网络流写出需要使用flush，这里在printWriter构造方法直接设置为自动flush
return new PrintWriter(new OutputStreamWriter(socketOut,"utf-8"),true);
}
private BufferedReader getReader(Socket socket) throws IOException{
//获得输入流缓冲区的地址
InputStream socketIn=socket.getInputStream();
return new BufferedReader(new InputStreamReader(socketIn,"utf-8"));
}
第三步，服务端核心：
//单客户版本，每次只能与一个用户建立通信连接
public void Service(){
while (true){
Socket socket=null;
try {
//此处程序阻塞，监听并等待用户发起连接，有连接请求就生成一个套接字
socket=serverSocket.accept();
//本地服务器控制台显示客户连接的用户信息
System.out.println("New connection accepted:"+socket.getInetAddress());
BufferedReader br=getReader(socket);
//字符串输入流
PrintWriter pw=getWriter(socket);
//字符串输出流
pw.println("来自服务器消息：欢迎使用本服务！");
String msg=null;
//此处程序阻塞，每次从输入流中读入一行字符串
while ((msg=br.readLine())!=null){
//如果用户发送信息为”bye“，就结束通信
if(msg.equals("bye")){
pw.println("来自服务器消息：服务器断开连接，结束服务！");
System.out.println("客户端离开。");
break;
}
pw.println("来自服务器消息："+msg);
}
}catch (IOException e){
e.printStackTrace();
}finally {
try {
if (socket!=null)
socket.close();
//关闭socket连接以及相关的输入输出流
}catch (IOException e){
e.printStackTrace();
}
}
}
}
代码关键解析很清楚易懂。可以看到，服务端提供服务放到了一个While(true)里面，这是因为服务器程序需要一直运行，所以处理代码一般放在while(true)这种无限循环中，TCPServer运行一次，且自身不能终止运行，要终止它运行，只能通过强制方式(如在IDE环境强制关闭)。
四、TCP客户端(具体代码)
第一步，创建客户端套接字，定义类构造方法，实现输入输出流。
//单客户版本，每次只能与一个用户建立通信连接
public void Service(){
while (true){
Socket socket=null;
try {
//此处程序阻塞，监听并等待用户发起连接，有连接请求就生成一个套接字
socket=serverSocket.accept();
//本地服务器控制台显示客户连接的用户信息
System.out.println("New connection accepted:"+socket.getInetAddress());
BufferedReader br=getReader(socket);
//字符串输入流
PrintWriter pw=getWriter(socket);
//字符串输出流
pw.println("来自服务器消息：欢迎使用本服务！");
String msg=null;
//此处程序阻塞，每次从输入流中读入一行字符串
while ((msg=br.readLine())!=null){
//如果用户发送信息为”bye“，就结束通信
if(msg.equals("bye")){
pw.println("来自服务器消息：服务器断开连接，结束服务！");
System.out.println("客户端离开。");
break;
}
pw.println("来自服务器消息："+msg);
}
}catch (IOException e){
e.printStackTrace();
}finally {
try {
if (socket!=null)
socket.close();
//关闭socket连接以及相关的输入输出流
}catch (IOException e){
e.printStackTrace();
}
}
}
}
第二步，实现网络通信发送和接收方法。
public void send(String msg){
//输出字符流，由socket调用系统底层函数，经网卡发送字节流
pw.println(msg);
}
public String receive(){
String msg=null;
try {
//从网络输入字符流中读取信息，每次只能接受一行信息
//不够一行时(无行结束符)，该语句阻塞
//直到条件满足，程序往下运行
msg=br.readLine();
}catch (IOException e){
e.printStackTrace();
}
return msg;
}
第三步，定义网络连接关闭方法供外部调用。
public void close(){
try {
if (socket!=null)
socket.close();
}catch (IOException e){
e.printStackTrace();
}
}
TCP连接的释放也有“四次握手”一说，必须经过2MSL后才真正释放。具体过程如下图：
文章图片
五、通信效果演示
文章图片
GIF动图演示：
文章图片
六、“创意”机器人：价值一个亿的AI核心代码(具体代码)
这部分我们要实现“聊天机器人”，效果这样：
文章图片
是不是迫不及待想知道如何实现呢！堪称“价值一个亿的AI核心代码”！！？？
就这样实现了！
文章图片
不卖关子了，就一行代码！
msg=msg.replace("?","!").replace("？","!").replace("吗","").replace("吗？","");
【java|java socket 通信协议_使用java如何实现基于TCP协议网络socket编程】关于使用java如何实现基于TCP协议网络socket编程问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注亿速云行业资讯频道了解更多相关知识。
推荐阅读
- JAVA|【Java学习】网络编程全总结——TCP、Udp、多线程、IO流、Socket、简易在线咨询聊天室、Java爬虫
- JAVA|基于TCP的网络编程——简单聊天程序
- java|java socket 服务端_Java通过 Socket 实现 TCP服务端
- spring|SpringBoot 2整合SpringSecurity权限管理（一）SpringSecurity介绍及简单搭建
- 使用Minio遇见的一些坑
- #|性能测试_Day_05（jmeter函数助手、json断言、beanshell、参数化）
- java|SpringBoot从入门到入门学习笔记
- spring|SpringBoot 集成minio MinioClient无法依赖问题-已解决
- MyBatis|Spring Boot（十）（Druid的监控统计和多数据源配置）