【JavaEE】网络编程---TCP数据报套接字编程

一、TCP数据报套接字编程

1.1 ServerSocket API

ServerSocket 是创建TCP服务端Socket的API
ServerSocket 构造方法:
在这里插入图片描述
ServerSocket 方法:
在这里插入图片描述

1.2 Socket API

Socket 是客户端Socket,或服务端中接收到客户端建立连接(accept方法)的请求后,返回的服务端Socket。不管是客户端还是服务端Socket,都是双方建立连接以后,保存的对端信息,及用来与对方收发数据的。
Socket 构造方法:

在这里插入图片描述
Socket 方法:
在这里插入图片描述
通过上述字节流对象进行数据传输:
InputStream读数据就相当于从网卡接收
OutputStream写数据就相当于从网卡发送

1.3 短连接和长连接

短连接:一次连接只有一个请求
长连接:一次连接有多个请求

1.4 示例一:回显服务器(echo server)

这里我们演示长连接:

1.4.1 Tcp服务器

package Tcp;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoServer {//serverSocket是外场拉客的小哥,serverSocket有且只有一个//cilentSocket是内场服务的小姐姐,cilentSocket会给每个客户端分配一个private ServerSocket serverSocket = null;public TcpEchoServer(int port) throws IOException {serverSocket = new ServerSocket(port);}public void start() throws IOException {System.out.println("服务器启动!");while(true) {Socket cilentSocket = serverSocket.accept();processConnection(cilentSocket);  //连接后通过processConnection来处理连接}}//通过这个方法来处理一个连接://1.读取请求//2.根据请求计算响应//3.把响应返回给客户端private void processConnection(Socket clientSocket) throws IOException {System.out.printf("[%s:%d] 客户端上线!\n", clientSocket.getInetAddress().toString(),clientSocket.getPort());  //提示客户端上线并打印IP地址和端口号//try()这种写法,允许括号中写多个流对象,中间使用“;”来分割try (InputStream inputStream = clientSocket.getInputStream();OutputStream outputStream = clientSocket.getOutputStream()) {Scanner scanner = new Scanner(inputStream);  //为了读取请求方便,把字节流转为字符流PrintWriter printWriter = new PrintWriter(outputStream); //为了返回响应方便,把字节流转为字符流//我们读到哪里算是一个完整的请求呢;//此处做一个简单的约定://每个请求是个字符串(文本数据),每个请求之间使用\n来分割,不要忘记响应也要这样约定while(true) {  //长连接:一次连接有多个请求//1.读取请求if (!scanner.hasNext()) {  //如果客户端关闭连接了,hasNext返回false,结束while循环System.out.printf("[%s:%d] 客户端下线!\n",clientSocket.getInetAddress().toString(),clientSocket.getPort());  //提示客户端下线并打印IP地址和端口号break;}//如果没有读完,直接使用scanner读取一段字符串String request = scanner.next();  //next会往后一直读直到读到空白符(空格、换行符、制表符、翻页符等)结束(不包含空白符)。此处尽量不要使用nextLine//2.根据请求计算响应String response = process(request);  //通过process方法来处理请求并返回响应//3.把响应返回给客户端(不要忘记响应里面也是要带上换行的,方便客户端区分从哪里到哪里是一个响应)printWriter.println(response);System.out.printf("[%s:%d] req:%s ; resp:%s \n",clientSocket.getInetAddress().toString(),clientSocket.getPort(),request,response);}} catch (IOException e) {e.printStackTrace();} finally {clientSocket.close();  //这里的cilentSocket只是给一个连接提供帮助,所以要及时释放}}private String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpEchoServer tcpEchoServer = new TcpEchoServer(9090);tcpEchoServer.start();}
}

注意:如果没有客户端连接时,accept是会阻塞的

1.4.2 Tcp客户端

package Tcp;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;public class TcpEchoClient {private Socket socket = null;private void TcpEchoServer(String serverIP, int port) throws IOException {//这个操作就相当于让客户端和服务端建立Tcp连接了socket = new Socket(serverIP,port);}public void start() throws IOException {Scanner scanner = new Scanner(System.in);try (InputStream inputStreamt = socket.getInputStream(); OutputStream outputStream = socket.getOutputStream()){PrintWriter printWriter = new PrintWriter(outputStream);Scanner scanner1 = new Scanner(inputStreamt);while (true) {//1.从键盘上读取用户输入的内容System.out.println("->");String request = scanner.next();//2.把输入的内容构造成请求并发送给服务器(对应服务器的接收)//注意这里发送的请求带有换行printWriter.println(request);//3.从服务器读取相应内容String response = scanner1.next();//4.把响应结果显示在控制台上System.out.printf("req: %s; resp: %s\n", request, response);}}}public static void main(String[] args) throws IOException {TcpEchoClient client = new TcpEchoClient("127.0.0.1", 9090);client.start();}}

我们运行发现:
在这里插入图片描述
在这里插入图片描述
此时服务器已经启动且客户端也上线了,我们输入的请求为什么没有响应呢?
我们服务器这里的代码:
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这两个地方加上就可以正常运行了:
在这里插入图片描述
在这里插入图片描述
这样子我们的代码貌似没什么问题了
可是这里还有一个很严重的bug:咱们的服务器一次只能给一个客户端提供服务!!
在idea中默认只能启动一个客户端,我们需要稍微设置一下:
在这里插入图片描述
此时可以有两个客户端:
在这里插入图片描述
但是我们发现只有一个客户端上线了:
在这里插入图片描述
在第一个客户端输入正常,第二个没有任何响应:
在这里插入图片描述
在这里插入图片描述

当前服务器无法服务多个客户端!!!===》代码bug

在这里插入图片描述
怎么解决这个问题呢?

我们希望能够该客户端1提供循环服务的同时又能够循环的调用accept

我们对服务器代码的start函数做如下改变:

public void start() throws IOException {System.out.println("服务器启动!");while(true) {Socket cilentSocket = serverSocket.accept();// 如果直接调用, 该方法会影响这个循环的二次执行, 导致 accept 不及时了.// 创建新的线程, 用新线程来调用 processConnection// 每次来一个新的客户端都搞一个新的线程即可Thread t = new Thread(() -> {try {processConnection(cilentSocket);  //连接后通过processConnection来处理连接} catch (IOException e) {throw new RuntimeException(e);}});t.start();}}

此时服务器便可同时处理多个客户端:
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/168969.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

WordPress SMTP邮件发送插件 Easy WP SMTP

Easy WP SMTP是一款 WordPress 邮件发送插件,WordPress 中经常用到邮件发送,包括新注册用户的邮件通知、找回密码通知、评论回复通知等。因为云服务器默认不启用 SMTP功能,所以需要安装 SMTP插件来解决这个问题。 SMTP 主机:smtp.…

Kurento多对多webrtc会议搭建测试

环境ubuntu18.04 KMS版本6.13.0 多对多通信demo7.0.0 KMS运行起来后,通过运行它的一个个demo,来实现不同的功能,它的demo很多如下: https://github.com/Kurento 里面有一对一,多对多,还有一些特效的demo。…

汽车屏类产品(三):抬头显示Head-Up Display(HUD)

前言 你的下一台车,一定要考虑加装一个HUD。 汽车抬头显示器或汽车抬头显示器(也称为汽车HUD)是任何透明的显示器,它可以在汽车中显示数据,而不需要用户将视线从平时的视角移开。这个名字的由来源于飞行员能够在头部“向上”并向前看的情况下查看信息,而不是向下倾斜查…

ARM可用的可信固件项目简介

安全之安全(security)博客目录导读 目录 一、TrustedFirmware-A (TF-A) 二、MCUboot 三、TrustedFirmware-M (TF-M) 四、TF-RMM 五、OP-TEE 六、Mbed TLS 七、Hafnium 八、Trusted Services 九、Open CI 可信固件为Armv8-A、Armv9-A和Armv8-M提供了安全软件的参考实现…

强化学习代码实战(2) --- 多臂赌博机

目录 前言 1.Python基础 2.Numpy基础 3.多臂赌博机 参考文献 前言 本文内容来自于南京大学郭宪老师在博文视点学院录制的视频,课程仅9元地址,配套书籍为深入浅出强化学习 编程实战 郭宪地址。 1.Python基础 1. print() 可以用该语句查看当前数据的情…

基于食肉植物优化的BP神经网络(分类应用) - 附代码

基于食肉植物优化的BP神经网络(分类应用) - 附代码 文章目录 基于食肉植物优化的BP神经网络(分类应用) - 附代码1.鸢尾花iris数据介绍2.数据集整理3.食肉植物优化BP神经网络3.1 BP神经网络参数设置3.2 食肉植物算法应用 4.测试结果…

MSP430F5529时钟系统配置

1、为什么要进行时钟管理?   时钟系统是一个数字器件的命脉,对于普通的51单片机来说,它的时钟来源只有外部晶振,然后每12个振荡周期完成一个基本操作,所以也叫做12T单片机,但对于当前高级一点的单片机来…

一文解读 SmartX 超融合虚拟化下的网络 I/O 虚拟化技术

随着技术的不断发展,不少行业应用都对网络性能和隔离性有着越来越高的要求。例如: 低延迟:一些期货行业用户选择在期货公司机房托管服务器并自行编写交易程序,以实现对市场波动的快速(微秒级)反应。尤其是在…

并查集讲解

并查集讲解 一、算法描述二、图示讲解三、代码示例四、例题练习 一、算法描述 并查集算法是一种用于处理不相交集合数据结构的算法。它经常被用来解决网络流问题、图的最小生成树问题等。在这篇博客中,我们将深入理解并查集算法,以及如何在实际编程中使…

设计模式思维导图

ProcessOn思维导图链接

睿趣科技:抖音小店申请流程

随着移动互联网的发展,越来越多的人开始尝试通过开设网店来创业。抖音作为国内最受欢迎的短视频平台之一,也推出了自己的电商功能——抖音小店。那么,如何申请抖音小店呢?下面就为大家详细介绍一下抖音小店的申请流程。 首先,打开…

基于springboot实现CSGO赛事管理系统【项目源码+论文说明】计算机毕业设计

基于SpringBoot实现CSGO赛事管理系统演示 摘要 CSGO赛事管理系统是针对CSGO赛事管理方面必不可少的一个部分。在CSGO赛事管理的整个过程中,CSGO赛事管理系统担负着最重要的角色。为满足如今日益复杂的管理需求,各类的管理系统也在不断改进。本课题所设计…

Redis的五种常用(基本)数据类型

目录 1、Redis简介 2、五种常用(基本)数据类型 2.1 String 数据结构 ⭐常用用法 举例(Linux版本) 2.2 List 数据结构 ⭐常用用法 举例(Linux版本) 2.3 Set 数据结构 ⭐常用用法 举例&#xf…

youyeetoo R1卡片电脑(rk3588s)

简介: youyeetoo R1 是风火轮科技专为AIOT市场设计的嵌入式主板(SBC),体积小但功能强大,搭载瑞芯微旗舰级RK3588s 八核64位处理器,8nm 制程,主频高达2.4GHz,集成ARM Mali-G610 MP4 GPU,内置6 To…

「必看」一分钟学会!Steam账号注册全攻略!

Steam账号注册详细教程,你值得拥有!💥 👋 Hello各位亲爱的小伙伴们!今天我要给大家带来的是一份超详细的Steam账号注册教程,让你轻松成为Steam世界的合法居民!🎉🎉 1️…

2023版 STM32实战11 SPI总线读写W25Q

SPI全称 英文全称:Serial peripheral Interface 串行外设接口 SPI特点 -1- 串行(逐bit传输) -2- 同步(共用时钟线) -3- 全双工(收发可同时进行) -4- 通信只能由主机发起(一主,多从机) 开发使用习惯和理解 -1- CS片选一般配置为软件控制 -2- 片选低电平有效,从…

开源博客项目Blog .NET Core源码学习(4:生成验证码)

开源博客项目Blog中的后台管理登录界面中支持输入验证码(如下图所示),本文学习并记录项目中验证码的生成及调用方式。   博客项目中调用VerifyCode类生成验证码,该类位于App.Framwork项目中,命名空间为App.Framwork…

基于Java的线上花店管理系统设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序(小蔡coding) 代码参考数据库参考源码获取 前言 💗博主介绍:✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计划导师、全栈领域优质创作者&am…

Redis数据类型

Redis数据类型 文章目录 Redis数据类型0.基本命令(1)key操作命令(2)注意 1.字符串(String)(1)set key value(2)mset /mget(3)getrange/setrange(4…

I/O模型之非阻塞IO

简介 五种IO模型   阻塞IO   非阻塞IO   信号驱动IO   IO多路转接    异步IO 代码书写 非阻塞IO 再次理解IO 什么是IO?什么是高效的IO? 为了理解后面的一个问题,我们首先要再重新理解一下什么是IO 在之前的网络介绍中&#xff…