网络编程、UDP、TCP协议
文章目录
- 网络编程
- 网络编程概述【理解】
- 计算机网络
- 网络编程
- 网络编程三要素【理解】
- IP地址
- 端口
- 协议
- IP地址【理解】
- IP地址:是网络中设备的唯一标识
- InetAddress【应用】
- 相关方法
- 代码演示
- 端口和协议【理解】
- 端口
- 端口号
- UDP协议
- TCP协议
- UDP通信程序
- UDP发送数据【应用】
- Java中的UDP通信
- 相关方法
- 代码演示
- UDP接收数据【应用】
- 接收数据的步骤
- 构造方法
- 相关方法
- 示例代码
- UDP通信程序练习(掌握)
- 案例需求
- 代码实现
- UDP三种通讯方式【理解】
- 单播
- 组播
- 广播
- UDP组播实现【了解】
- 实现步骤
- 发送端
- 接收端
- 代码实现
- UDP广播实现【理解】
- 实现步骤
- 发送端
- 接收端
- 代码实现
- TCP通信程序
- TCP发送数据
- 构造方法
- 相关方法
- 示例代码
- TCP接收数据
- 构造方法
- 相关方法
- 三次握手和四次挥手
- 模拟场景
- 三次握手:
- 四次挥手:
- 示例代码
- TCP程序练习
- 案例需求
- 案例分析
- TCP程序文件上传练习
- 案例需求
- 案例分析
- 相关方法
- 代码实现
- TCP程序服务器优化
- 优化方案一
- 解决方案
- 代码实现
- 优化方案二
- 解决方案
- 代码实现
- 优化方案三
- 解决方案
- 代码实现
- 优化方案四
- 解决方案
- 代码实现
网络编程
网络编程概述【理解】
计算机网络
是指将地理位置不同的具有独立功能的多台计算机及其外部设备,通过通信线路连接起来,在网络操作系统,网络管理软件及网络通信协议的管理和协调下,实现资源共享和信息传递的计算机系统
网络编程
在网络通信协议下,不同计算机上运行的程序,可以进行数据传输
网络编程三要素【理解】
IP地址
要想让网络中的计算机能够互相通信,必须为每台计算机指定一个标识号,通过这个标识号来指定要接收数据的计算机和识别发送的计算机,而IP地址就是这个标识号。也就是设备的标识
端口
网络的通信,本质上是两个应用程序的通信。每台计算机都有很多的应用程序,那么在网络通信时,如何区分这些应用程序呢?如果说IP地址可以唯一标识网络中的设备,那么端口号就可以唯一标识设备中的应用程序了。也就是应用程序的标识
协议
通过计算机网络可以使多台计算机实现连接,位于同一个网络中的计算机在进行连接和通信时需要遵守一定的规则,这就好比在道路中行驶的汽车一定要遵守交通规则一样。在计算机网络中,这些连接和通信的规则被称为网络通信协议,它对数据的传输格式、传输速率、传输步骤等做了统一规定,通信双方必须同时遵守才能完成数据交换。常见的协议有UDP协议和TCP协议
IP地址【理解】
IP地址:是网络中设备的唯一标识
IP地址分为两大类
IPv4:是给每个连接在网络上的主机分配一个32bit地址。按照TCP/IP规定,IP地址用二进制来表示,每个IP地址长32bit,也就是4个字节。例如一个采用二进制形式的IP地址是“11000000 10101000 00000001 01000010”,这么长的地址,处理起来也太费劲了。为了方便使用,IP地址经常被写成十进制的形式,中间使用符号“.”分隔不同的字节。于是,上面的IP地址可以表示为“192.168.1.66”。IP地址的这种表示法叫做“点分十进制表示法”,这显然比1和0容易记忆得多
IPv6:由于互联网的蓬勃发展,IP地址的需求量愈来愈大,但是网络地址资源有限,使得IP的分配越发紧张。为了扩大地址空间,通过IPv6重新定义地址空间,采用128位地址长度,每16个字节一组,分成8组十六进制数,这样就解决了网络地址资源数量不够的问题
DOS常用命令:
ipconfig:查看本机IP地址
ping IP地址:检查网络是否连通
特殊IP地址:
127.0.0.1:是回送地址,可以代表本机地址,一般用来测试使用
InetAddress【应用】
InetAddress:此类表示Internet协议(IP)地址
相关方法
方法名 | 说明 |
---|---|
static InetAddress getByName(String host) | 确定主机名称的IP地址。主机名称可以是机器名称,也可以是IP地址 |
String getHostName() | 获取此IP地址的主机名 |
String getHostAddress() | 返回文本显示中的IP地址字符串 |
代码演示
端口和协议【理解】
端口
设备上应用程序的唯一标识
端口号
用两个字节表示的整数,它的取值范围是065535。其中,01023之间的端口号用于一些知名的网络服务和应用,普通的应用程序需要使用1024以上的端口号。如果端口号被另外一个服务或应用所占用,会导致当前程序启动失败
协议
计算机网络中,连接和通信的规则被称为网络通信协议
UDP协议
用户数据报协议(User Datagram Protocol)
UDP是无连接通信协议,即在数据传输时,数据的发送端和接收端不建立逻辑连接。简单来说,当一台计算机向另外一台计算机发送数据时,发送端不会确认接收端是否存在,就会发出数据,同样接收端在收到数据时,也不会向发送端反馈是否收到数据。
由于使用UDP协议消耗系统资源小,通信效率高,所以通常都会用于音频、视频和普通数据的传输
例如视频会议通常采用UDP协议,因为这种情况即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。但是在使用UDP协议传送数据时,由于UDP的面向无连接性,不能保证数据的完整性,因此在传输重要数据时不建议使用UDP协议
TCP协议
传输控制协议 (Transmission Control Protocol)
TCP协议是面向连接的通信协议,即传输数据之前,在发送端和接收端建立逻辑连接,然后再传输数据,它提供了两台计算机之间可靠无差错的数据传输。在TCP连接中必须要明确客户端与服务器端,由客户端向服务端发出连接请求,每次连接的创建都需要经过“三次握手”
三次握手:TCP协议中,在发送数据的准备阶段,客户端与服务器之间的三次交互,以保证连接的可靠
第一次握手,客户端向服务器端发出连接请求,等待服务器确认
第二次握手,服务器端向客户端回送一个响应,通知客户端收到了连接请求
第三次握手,客户端再次向服务器端发送确认信息,确认连接
完成三次握手,连接建立后,客户端和服务器就可以开始进行数据传输了。由于这种面向连接的特性,TCP协议可以保证传输数据的安全,所以应用十分广泛。例如上传文件、下载文件、浏览网页等
UDP通信程序
UDP发送数据【应用】
Java中的UDP通信
UDP协议是一种不可靠的网络协议,它在通信的两端各建立一个Socket对象,但是这两个Socket只是发送,接收数据的对象,因此对于基于UDP协议的通信双方而言,没有所谓的客户端和服务器的概念
Java提供了DatagramSocket类作为基于UDP协议的Socket
构造方法
方法名 | 说明 |
---|---|
DatagramSocket() | 创建数据报套接字并将其绑定到本机地址上的任何可用端 |
DatagramPacket(byte[] buf,int len,InetAddress add,int port) | 创建数据包,发送长度为len的数据包到指定主机的指定端口 |
相关方法
方法名 | 说明 |
---|---|
void send(DatagramPacket p) | 发送数据报包 |
void close() | 关闭数据报套接字 |
void receive(DatagramPacket p) | 从此套接字接受数据报包 |
发送数据的步骤 |
- 创建发送端的Socket对象(DatagramSocket)
- 创建数据,并把数据打包
- 调用DatagramSocket对象的方法发送数据
- 关闭发送端
代码演示
public static void main(String[] args) throws IOException {//- 1创建发送端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket();//- 2创建数据,并把数据打包String s = "你好";//2.1把字符串转为字节数组byte[] bytes = s.getBytes("gbk");//2.2创建InetAddress对象 里面写入目标地址的ipInetAddress addr = InetAddress.getByName("127.0.0.1");//2.3 打包数据// 参是1 是要发送的数据的字节数组,参2是发送的数组的长度,参3 目标的ip地址的InetAddress对象,参4目标的端口DatagramPacket packet = new DatagramPacket(bytes, bytes.length, addr, 10000);//- 3调用DatagramSocket对象的方法发送数据ds.send(packet);//- 4关闭发送端ds.close();}
UDP接收数据【应用】
接收数据的步骤
- 创建接收端的Socket对象(DatagramSocket)
- 创建一个数据包,用于接收数据
- 调用DatagramSocket对象的方法接收数据
- 解析数据包,并把数据在控制台显示
- 关闭接收端
构造方法
方法名 | 说明 |
---|---|
DatagramPacket(byte[] buf, int len) | 创建一个DatagramPacket用于接收长度为len的数据包 |
相关方法
方法名 | 说明 |
---|---|
byte[] getData() | 返回数据缓冲区 |
int getLength() | 返回要发送的数据的长度或接收的数据的长度 |
示例代码
//- 1创建接收端的Socket对象(DatagramSocket)
//接收的程序 写明端口号 如果不写 每次运行都会自动分配一个不一样的端口
DatagramSocket ds = new DatagramSocket(10000);//- 2创建一个数据包,用于接收数据
byte[] bytes = new byte[1024];
//参1是装接收的数据的字节数据,参2表示接收多长的数据装到数组里
DatagramPacket dp = new DatagramPacket(bytes, bytes.length);//- 3调用DatagramSocket对象的方法接收数据f
System.out.println(1111);
ds.receive(dp);
System.out.println(222);//- 4解析数据包,并把数据在控制台显示
//getData获取数据包中的字节数组
byte[] data = dp.getData();
//dp.getLength()是接收的数据的长度
System.out.println(new String(data, 0, dp.getLength(), "gbk"));//- 5关闭接收端
ds.close();
UDP通信程序练习(掌握)
案例需求
UDP发送数据:数据来自于键盘录入,可以一直发,直到输入的数据是886,发送数据结束
UDP接收数据:因为接收端不知道发送端什么时候停止发送,故采用死循环接收
代码实现
/*UDP发送数据:数据来自于键盘录入,直到输入的数据是886,发送数据结束*/
public class Send {public static void main(String[] args) throws IOException {//1创建socket对象DatagramSocket ds = new DatagramSocket();//2键盘录入Scanner sc = new Scanner(System.in);while (true) {//获取发送的数据System.out.println("请输入数据");String text = sc.next();if ("886".equals(text)) {break;}//3 打包数据包//数据转为字节数组byte[] bytes = text.getBytes();//目标ipInetAddress addr = InetAddress.getByName("192.168.12.75");//创建好数据包DatagramPacket packet = new DatagramPacket(bytes, bytes.length, addr, 14000);ds.send(packet);System.out.println("发送成功");}ds.close();}
}
/*UDP接收数据:因为接收端不知道发送端什么时候停止发送,故采用死循环接收*/
public class Receive {public static void main(String[] args) throws IOException {//1创建socket对象 端口13000DatagramSocket ds = new DatagramSocket(14000);while (true) {//2创建接收的数组和数据包byte[] bytes = new byte[1024];DatagramPacket packet = new DatagramPacket(bytes, bytes.length);System.out.println("等待接收数据");//3接收数据ds.receive(packet);//4打印数据System.out.println(new String(packet.getData(), 0, packet.getLength()));}//ds.close();}
}
UDP三种通讯方式【理解】
单播
单播用于两个主机之间的端对端通信
组播
组播用于对一组特定的主机进行通信,224.0.0.0~239.255.255.255
广播
广播用于一个主机对整个局域网上所有主机上的数据通信
UDP组播实现【了解】
组播的ip范围 224.0.0.0~239.255.255.255
实现步骤
发送端
创建发送端的Socket对象(DatagramSocket)
创建数据,并把数据打包(DatagramPacket)
调用DatagramSocket对象的方法发送数据(在单播中,这里是发给指定IP的电脑但是在组播当中,这里是发给组播地址)
释放资源
接收端
创建接收端Socket对象(MulticastSocket)
创建一个箱子,用于接收数据
把当前计算机绑定一个组播地址
将数据接收到箱子中
解析数据包,并打印数据
释放资源
代码实现
// 发送端
public class ClinetDemo {public static void main(String[] args) throws IOException {// 1. 创建发送端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket();String s = "hello 组播";byte[] bytes = s.getBytes();InetAddress address = InetAddress.getByName("224.0.1.0");int port = 10000;// 2. 创建数据,并把数据打包(DatagramPacket)DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,port);// 3. 调用DatagramSocket对象的方法发送数据(在单播中,这里是发给指定IP的电脑但是在组播当中,这里是发给组播地址)ds.send(dp);// 4. 释放资源ds.close();}
}
// 接收端
public class ServerDemo {public static void main(String[] args) throws IOException {// 1. 创建接收端Socket对象(MulticastSocket)MulticastSocket ms = new MulticastSocket(10000);// 2. 创建一个箱子,用于接收数据DatagramPacket dp = new DatagramPacket(new byte[1024],1024);// 3. 把当前计算机绑定一个组播地址,表示添加到这一组中.ms.joinGroup(InetAddress.getByName("224.0.1.0"));// 4. 将数据接收到箱子中ms.receive(dp);// 5. 解析数据包,并打印数据byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data,0,length));// 6. 释放资源ms.close();}
}
UDP广播实现【理解】
实现步骤
发送端
创建发送端Socket对象(DatagramSocket)
创建存储数据的箱子,将广播地址封装进去
发送数据
释放资源
接收端
创建接收端的Socket对象(DatagramSocket)
创建一个数据包,用于接收数据
调用DatagramSocket对象的方法接收数据
解析数据包,并把数据在控制台显示
关闭接收端
代码实现
// 发送端
public class ClientDemo {public static void main(String[] args) throws IOException {// 1. 创建发送端Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket();// 2. 创建存储数据的箱子,将广播地址封装进去String s = "广播 hello";byte[] bytes = s.getBytes();InetAddress address = InetAddress.getByName("255.255.255.255");int port = 10000;DatagramPacket dp = new DatagramPacket(bytes,bytes.length,address,port);// 3. 发送数据ds.send(dp);// 4. 释放资源ds.close();}
}
// 接收端
public class ServerDemo {public static void main(String[] args) throws IOException {// 1. 创建接收端的Socket对象(DatagramSocket)DatagramSocket ds = new DatagramSocket(10000);// 2. 创建一个数据包,用于接收数据DatagramPacket dp = new DatagramPacket(new byte[1024],1024);// 3. 调用DatagramSocket对象的方法接收数据ds.receive(dp);// 4. 解析数据包,并把数据在控制台显示byte[] data = dp.getData();int length = dp.getLength();System.out.println(new String(data,0,length));// 5. 关闭接收端ds.close();}
}
TCP通信程序
一开始就接收的一端:服务器, 要先运行 ,等待客户端连接
一开始就发送的一端:客户端,主动去连接服务器
TCP发送数据
Java中的TCP通信
Java对基于TCP协议的的网络提供了良好的封装,使用Socket对象来代表两端的通信端口,并通过Socket产生IO流来进行网络通信。
Java为客户端提供了Socket类,为服务器端提供了ServerSocket类
构造方法
方法名 | 说明 |
---|---|
Socket(InetAddress address,int port) | 创建流套接字并将其连接到指定IP指定端口号 |
Socket(String host, int port) | 创建流套接字并将其连接到指定主机上的指定端口号 |
相关方法
方法名 | 说明 |
---|---|
InputStream getInputStream() | 返回此套接字的输入流 |
OutputStream getOutputStream() | 返回此套接字的输出流 |
示例代码
public static void main(String[] args) throws IOException {//1创建socket对象//参数1和2是要连接的服务器的ip和端口Socket s = new Socket("192.168.27.58", 13000);System.out.println("连接成功");//获取发送数据用的字节流对象OutputStream os = s.getOutputStream();//写入数据os.write("hehe".getBytes());//os.close();//关闭套接字s.close();
}
TCP接收数据
构造方法
方法名 | 说明 |
---|---|
ServletSocket(int port) | 创建绑定到指定端口的服务器套接字 |
相关方法
方法名 | 说明 |
---|---|
Socket accept() | 监听要连接到此的套接字并接受它 |
注意事项 |
accept方法是阻塞的,作用就是等待客户端连接
客户端创建对象并连接服务器,此时是通过三次握手协议,保证跟服务器之间的连接
针对客户端来讲,一般是先往外写的,所以是输出流
针对服务器来讲,一般是先往里读的,所以是输入流
read方法也是阻塞的
客户端在关流的时候,还多了一个往服务器写结束标记的动作
最后一步断开连接,通过四次挥手协议保证连接终止
三次握手和四次挥手
三次握手
四次挥手
模拟场景
阿kun 和 阿花 是情侣,晚上放学后,阿kun回到男生宿舍,阿花回到女生宿舍
三次握手:
阿kun 给 阿花发信息:亲爱的,在忙吗,王者上线不?
阿花 给 阿kun : 我不忙,确定上线吗?
阿kun 给 阿花: 走起,开黑了。
四次挥手:
阿kun 给 阿花发信息:亲爱的,队友太坑了,我受不了了,我想强退了,休息了,你也休息吧
阿花 给 阿kun : 我马上结束,还差2个人头,马上就0-10了
阿花 给 阿kun : 亲爱的,我搞定了,可以休息了
阿kun 给 阿花: 好的,88 ,明天见
示例代码
public class ServerDemo {public static void main(String[] args) throws IOException {//创建服务器端的Socket对象(ServerSocket)//ServerSocket(int port) 创建绑定到指定端口的服务器套接字ServerSocket ss = new ServerSocket(15000);//这里等待客户端连接 会阻塞,一旦连接会返回一个处理此次连接的Socket对象Socket s = ss.accept();System.out.println("连接成功"+s.getRemoteSocketAddress());//获取输入流,读数据,并把数据显示在控制台InputStream is = s.getInputStream();byte[] bys = new byte[1024];int len = is.read(bys);String data = new String(bys,0,len);System.out.println("数据是:" + data);//释放资源s.close();ss.close();}
}
流程图
TCP程序练习
案例需求
客户端:发送数据,接受服务器反馈
服务器:收到消息后给出反馈
案例分析
客户端创建对象,使用输出流输出数据
服务端创建对象,使用输入流接受数据
服务端使用输出流给出反馈数据
客户端使用输入流接受反馈数据
代码实现
// 客户端
public class ClientDemo {public static void main(String[] args) throws IOException {Socket socket = new Socket("127.0.0.1",10000);OutputStream os = socket.getOutputStream();os.write("hello".getBytes());// os.close();如果在这里关流,会导致整个socket都无法使用socket.shutdownOutput();//仅仅关闭输出流.并写一个结束标记,对socket没有任何影响BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while((line = br.readLine())!=null){System.out.println(line);}br.close();os.close();socket.close();}
}
// 服务器
public class ServerDemo {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(10000);Socket accept = ss.accept();InputStream is = accept.getInputStream();int b;while((b = is.read())!=-1){System.out.println((char) b);}System.out.println("看看我执行了吗?");BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(accept.getOutputStream()));bw.write("你谁啊?");bw.newLine();bw.flush();bw.close();is.close();accept.close();ss.close();}
}
流程图
TCP程序文件上传练习
案例需求
客户端:数据来自于本地文件,接收服务器反馈
服务器:接收到的数据写入本地文件,给出反馈
案例分析
创建客户端对象,创建输入流对象指向文件,每读一次数据就给服务器输出一次数据,输出结束后使用shutdownOutput()方法告知服务端传输结束,会给服务器一个结束标记
创建服务器对象,创建输出流对象指向文件,每接受一次数据就使用输出流输出到文件中,传输结束后。使用输出流给客户端反馈信息
客户端接受服务端的回馈信息
相关方法
名字 | 描述 |
---|---|
void shutdownOutput() | 禁止用此套接字的输出流 |
代码实现
// 客户端
public class ClientDemo {public static void main(String[] args) throws IOException {Socket socket = new Socket("127.0.0.1",10000);//是本地的流,用来读取本地文件的.BufferedInputStream bis = new BufferedInputStream(new FileInputStream("xxx/1.jpg"));//写到服务器 --- 网络中的流OutputStream os = socket.getOutputStream();BufferedOutputStream bos = new BufferedOutputStream(os);int b;while((b = bis.read())!=-1){bos.write(b);//通过网络写到服务器中}bos.flush();//给服务器一个结束标记,告诉服务器文件已经传输完毕socket.shutdownOutput();BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));String line;while((line = br.readLine()) !=null){System.out.println(line);}bis.close();socket.close();}
}
// 服务器
public class ServerDemo {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(10000);Socket accept = ss.accept();//网络中的流,从客户端读取数据的BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());//本地的IO流,把数据写到本地中,实现永久化存储BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("socketmodule\\ServerDir\\copy.jpg"));int b;while((b = bis.read()) !=-1){bos.write(b);}BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(accept.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();bos.close();accept.close();ss.close();}
}
TCP程序服务器优化
优化方案一
问题:
服务器目前只能处理一个客户端请求,接收完一个文件之后,服务器就关闭了。
解决方案
使用循环
代码实现
// 服务器代码如下,客户端代码同上个案例,此处不再给出
public class ServerDemo {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(10000);while (true) {Socket accept = ss.accept();//网络中的流,从客户端读取数据的BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());//本地的IO流,把数据写到本地中,实现永久化存储BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("optimizeserver\\ServerDir\\copy.jpg"));int b;while((b = bis.read()) !=-1){bos.write(b);}BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(accept.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();bos.close();accept.close();}//ss.close();}
}
优化方案二
问题:
第二次上传文件的时候,会把第一次的文件给覆盖。
解决方案
UUID. randomUUID()方法生成随机的文件名
代码实现
// 服务器代码如下,客户端代码同上个案例,此处不再给出
public class ServerDemo {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(10000);while (true) {Socket accept = ss.accept();//网络中的流,从客户端读取数据的BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());//本地的IO流,把数据写到本地中,实现永久化存储BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream("optimizeserver\\ServerDir\\" + UUID.randomUUID().toString() + ".jpg"));int b;while((b = bis.read()) !=-1){bos.write(b);}BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(accept.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();bos.close();accept.close();}//ss.close();}
}
优化方案三
问题
使用循环虽然可以让服务器处理多个客户端请求。但是还是无法同时跟多个客户端进行通信。
解决方案
开启多线程处理
代码实现
// 线程任务类
public class ThreadSocket implements Runnable {private Socket acceptSocket;public ThreadSocket(Socket accept) {this.acceptSocket = accept;}@Overridepublic void run() {BufferedOutputStream bos = null;try {//网络中的流,从客户端读取数据的BufferedInputStream bis = new BufferedInputStream(acceptSocket.getInputStream());//本地的IO流,把数据写到本地中,实现永久化存储bos = new BufferedOutputStream(new FileOutputStream("optimizeserver\\ServerDir\\" + UUID.randomUUID().toString() + ".jpg"));int b;while((b = bis.read()) !=-1){bos.write(b);}BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(acceptSocket.getOutputStream()));bw.write("上传成功");bw.newLine();bw.flush();} catch (IOException e) {e.printStackTrace();} finally {if(bos != null){try {bos.close();} catch (IOException e) {e.printStackTrace();}}if (acceptSocket != null){try {acceptSocket.close();} catch (IOException e) {e.printStackTrace();}}}}
}
// 服务器代码
public class ServerDemo {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(10000);while (true) {Socket accept = ss.accept();ThreadSocket ts = new ThreadSocket(accept);new Thread(ts).start();}//ss.close();}
}
优化方案四
需求
使用多线程虽然可以让服务器同时处理多个客户端请求。但是资源消耗太大。
解决方案
加入线程池
代码实现
// 服务器代码如下,线程任务类代码同上,此处不再给出
public class ServerDemo {public static void main(String[] args) throws IOException {ServerSocket ss = new ServerSocket(10000);ThreadPoolExecutor pool = new ThreadPoolExecutor(3,//核心线程数量10, //线程池的总数量60, //临时线程空闲时间TimeUnit.SECONDS, //临时线程空闲时间的单位new ArrayBlockingQueue<>(5),//阻塞队列Executors.defaultThreadFactory(),//创建线程的方式new ThreadPoolExecutor.AbortPolicy()//任务拒绝策略);while (true) {Socket accept = ss.accept();ThreadSocket ts = new ThreadSocket(accept);//new Thread(ts).start();pool.submit(ts);}//ss.close();}
}
网络编程、UDP、TCP协议相关推荐
- 网络编程——基于TCP协议的通讯录【课程设计】
网络编程--基于TCP协议的通讯录[课程设计] 本文目录 网络编程--基于TCP协议的通讯录[课程设计] 一.设计题目和要求 设计目标: 课程设计系统组成及模块功能: 二.设计内容 服务端 客户端 S ...
- 基于ZYNQ-7000的AI加速器设计之PS端(ARM)网络编程(TCP协议)
前注:ARM端的TCP协议编程步骤和UDP协议编程步骤完全相同,只是在ARM端的C代码实现不同,在本次TCP协议实现过程中我们主要利用了官方提供的Demo,然后根据自己的需要加以改写,具体过程如下. ...
- java 网络编程 UDP TCP
网络编程 网络编程主要用于解决计算机与计算机(手机.平板..)之间的数据传输问题. 网络编程: 不需要基于html页面就可以达到数据之间的传输. 比如: feiQ , QQ , 微信.... 网页编程 ...
- Linux 系统应用编程——网络编程(TCP 协议三次握手过程)
TCP(Transmission Control Protocol) 传输控制协议 TCP是主机对主机层的传输控制协议,提供可靠的连接服务,采用三次握手确认建立一个连接: 位码即tcp标志位,有6种 ...
- JVAV——网络编程UDP/TCP
一: 计算机网络可以实现多台计算机的连接但不同的计算机操作系统和硬件体系结构不同,为了提供通信支持位于同一网络中的计算机必须要遵循一定的规则.目前应用最广泛的是TCP/IP,UDP,ICMP等协议. ...
- step5 . day6 网络编程 基于TCP协议的多并发模式(使用多进程、多线程、select函数分别实现)...
实现TCP服务器端多路并发的方法有①多进程②多线程③IO多路复用(select poll epoll函数) 1.多进程实现并发模式(仅在服务器端更改之前代码实现) 服务器端 #include < ...
- 网络编程 udp tcp的使用
111111 /*InetAddress此类表示Internet协议(IP)地址public static InetAddress getByName(String host):确定主机名称的IP地 ...
- Java学习笔记53(网络编程:TCP协议案例)
简易的案例 客户端: package demo;import java.io.IOException; import java.io.InputStream; import java.io.Outpu ...
- 网络编程及TCP/UDP协议
网络编程 1.1.概述 地球村:你在西安,一个在美国 打电话--连接--接了--通话 TCP 发短信--发完了就完事了--接收 UDP(丢包) 计算机网络: 计算机网络系统就是利用通信设备和线路将地理 ...
- 网络编程及三大协议(TCP + UDP + Http)
网络编程及三大协议(TCP + UDP + Http) 一.网络编程 1.计算机网络 是指将地理位置不同的具有独立功能的多台计算机及其外部设备,通过通信线路连接起来,在网络操作系统,网络管理软件及网络 ...
最新文章
- 2019.04.07 装饰器介绍
- POJ3114强连通+spfa
- SAP smartforms之Zebra print control language
- Null reference pointer was passed to the stub when not debugging with IE
- 文献学习(part78-B)--A Survey of Clustering Algorithms for Big Data: T axonomy Empirical Analysis
- Java之品优购课程讲义_day20(2)
- php无重复字符的最长子串,无重复字符的最长字串问题
- 8.docker search
- 关于本机及网络无法连接SQLEXPRESS的解决办法
- linux上多个CUDA切换使用(小白教程)
- 小孔子内容管理系统第一次更新
- Verilog学习之路(1)— Quartus II 13.0下载安装和HelloWorld
- JBoot 全网上最好用的 API 文档工具
- 【死磕opensips】sip协议解析
- 狂野飙车8服务器在哪个文件夹,狂野飙车8数据包放哪?安卓版数据包路径介绍
- C++ qsort用法
- 长安链---从零到一部署Chainmaker-2.0.0
- 【机器学习之路】(转载)
- 质量是企业的生命,如何破解质量管控难题?质量管理系统推荐
- 在Scope中利用Comment-input来列举我们的评论
热门文章
- vue中通过monment.js插件来将时间戳转换为常用的时间格式
- Java新浪微博客户端开发第三步
- html访问剪切板,如何根据指定的剪切板获取html?
- iMessage App 创建
- python代码看不懂可以从哪些地方找答案_99%的问题都能在网上找到答案,这就是学编程时的正确思路...
- java打断sleep_Java中sleep()和wait()的区别
- 学习电路的第一天(项 延迟)
- linux内核版本 2.6.14,Linux-2.6.14内核在S3C2410上的移植
- 航片ply点云文件转pcd点云文件 debug流程
- excel 不能分类汇总、分类汇总按钮是灰色的另一个原因