概述
文章目录
- 前言
- 一、概念
- 二、分类(三类)
- 2.1 流套接字:使用传输层TCP协议
- 2.2 数据报套接字:使用传输层UDP协议
- 2.3 原始套接字
- 三、UDP数据报套接字编程
- 3.1 Java数据报套接字通信模型
- 3.2 DatagramSocket API
- 3.2.1 ` DatagramSocket` 构造方法:
- 3.2.2 ` DatagramSocket` 普通方法(属于DatagramSocket类):
- 3.3 DatagramPacket API
- 3.3.1 ` DatagramPacket ` 构造方法:
- 3.3.2 ` DatagramPacket` 普通方法:
- 3.4 InetSocketAddress API
- 3.5 代码示例(有请求和相应)
- 四、TCP数据报套接字编程
- 4.1 Java流套接字通信模型
- 4.2 ServerSocket API
- 4.2.1 ` ServerSocket` 构造方法:
- 4.2. ` ServerSocket` 普通方法
- 4.3 Socket API
- 4.3.1 ` Socket` 构造方法:
- 4.3.2 ` Socket` 普通方法:
- 4.4 TCP中的长短连接
- 4.5 代码示例(短连接)
- 五、 关于输入流和输出流的使用
- 5.1 关于输入流的使用:
- 5.2 关于输出流的使用:
- 六、面向数据报文VS面向字节流
- 总结
前言
博主个人社区:开发与算法学习社区
博主个人主页:Killing Vibe的博客
欢迎大家加入,一起交流学习~~
一、概念
Socket套接字,是由系统提供用于网络通信的技术,是基于TCP/IP协议的网络通信的基本操作单元。基于Socket套接字的网络程序开发就是网络编程。
Socket是站在应用层,做网络编程很重要的一个概念
传输层、网络层、数据链路层、物理层 都是通过OS+硬件来提供服务的,而应用层要享受OS提供的网络服务,需要通过OS提供的服务窗口(Socket)来享受服务。
拓展:
OS原生的提供的系统调用(Linux上的网络编程):
int fd = socket();
setsocketopt(fd,TCP or UDP)
二、分类(三类)
Socket套接字主要针对传输层协议划分为如下三类:
2.1 流套接字:使用传输层TCP协议
TCP,即Transmission Control Protocol(传输控制协议),传输层协议。
以下为TCP的特点:
- 有连接
- 可靠传输
- 面向字节流
- 有接收缓冲区,也有发送缓冲区
- 大小不限
对于字节流来说,可以简单的理解为,传输数据是基于IO流,流式数据的特征就是在IO流没有关闭的情况下,是无边界的数据,可以多次发送,也可以分开多次接收。
2.2 数据报套接字:使用传输层UDP协议
UDP,即User Datagram Protocol(用户数据报协议),传输层协议。
以下为UDP的特点:
- 无连接
- 不可靠传输
- 面向数据报
- 有接收缓冲区,无发送缓冲区
- 大小受限:一次最多传输64k
对于数据报来说,可以简单的理解为,传输数据是一块一块的,发送一块数据假如100个字节,必须一次发送,接收也必须一次接收100个字节,而不能分100次,每次接收1个字节。
2.3 原始套接字
原始套接字用于自定义传输层协议,用于读写内核没有处理的IP协议数据。
三、UDP数据报套接字编程
对于UDP协议来说,具有无连接,面向数据报的特征,即每次都是没有建立连接,并且一次发送全部数据报,一次接收全部的数据报。
3.1 Java数据报套接字通信模型
java中使用UDP协议通信,主要基于 DatagramSocket
类来创建数据报套接字,并使用
DatagramPacket
作为发送或接收的UDP数据报。对于一次发送及接收UDP数据报的流程如下:
3.2 DatagramSocket API
DatagramSocket
是UDP Socket,用于发送和接收UDP数据报。
3.2.1 DatagramSocket
构造方法:
注意:
-
UDP服务器(Server):采用一个固定端口,方便客户端(Client)进行通信;
使用DatagramSocket(int port)
,就可以绑定到本机指定的端口,此方法可能有错误风险,提示该端口已经被其他进程占用。 -
UDP客户端(Client):不需要采用固定端口(也可以用固定端口),采用随机端口;
使用DatagramSocket()
,绑定到本机任意一个随机端口
3.2.2 DatagramSocket
普通方法(属于DatagramSocket类):
注意:
-
一旦通信双方逻辑意义上有了通信线路,双方地位就平等了(谁都可以作为发送方和接收方)
-
发送方调用的就是
send()
方法,接收方调用的就是receive()
方法 -
通信结束后,双方都应该调用
close()
方法进行资源回收
3.3 DatagramPacket API
DatagramPacket
是UDP Socket发送和接收的数据报。
这个类就是定义的报文包:通信过程中的数据抽象
可以理解为:发送/接受的一个信封(五元组+信件)
3.3.1 DatagramPacket
构造方法:
注意:
- 作为接收方:只需要提供存放接受数据的位置(byte[] buf + int length)
- 作为发送方:需要有要发送的数据(byte[] buf +int offset +int length),要发送给谁(远端ip+远端port)
3.3.2 DatagramPacket
普通方法:
注意:
- 一般给服务器使用的是
getAddress()
方法和getPort()
方法,用来获取客户端的ip地址和端口号port - 一般给接收者(可以是服务器也可是客户端)使用的是
getData()
,用来拿到“信”(对方进程发送的应用层数据)
3.4 InetSocketAddress API
InetSocketAddress ( SocketAddress 的子类 )构造方法:
3.5 代码示例(有请求和相应)
以下仅展示部分代码,完整代码可以看博主的gitee仓库:
网络开发代码
UDP客户端:
public class UserInputLoopClient {
public static void main(String[] args) throws Exception {
Scanner scanner = new Scanner(System.in);
// 1. 创建 UDP socket
Log.println("准备创建 UDP socket");
DatagramSocket socket = new DatagramSocket();
Log.println("UDP socket 创建结束");
System.out.print("请输入英文单词: ");
while (scanner.hasNextLine()) {
// 2. 发送请求
String engWord = scanner.nextLine();
Log.println("英文单词是: " + engWord);
String request = engWord;
byte[] bytes = request.getBytes("UTF-8");
// 手动构造服务器的地址
// 现在,服务器和客户端在同一台主机上,所以,使用 127.0.0.1 (环回地址 loopback address)
// 端口使用 TranslateServer.PORT(8888)
InetAddress loopbackAddress = InetAddress.getLoopbackAddress();
InetAddress remoteAddress = Inet4Address.getByName("182.254.132.183");
DatagramPacket sentPacket = new DatagramPacket(
bytes, 0, bytes.length, // 要发送的数据
remoteAddress, TranslateServer.PORT // 对方的 ip + port
);
Log.println("准备发送请求");
socket.send(sentPacket);
Log.println("请求发送结束");
// 3. 接收响应
byte[] buf = new byte[1024];
DatagramPacket receivedPacket = new DatagramPacket(buf, buf.length);
Log.println("准备接收响应");
socket.receive(receivedPacket);
Log.println("响应接收接收");
byte[] data = receivedPacket.getData();
int len = receivedPacket.getLength();
String response = new String(data, 0, len, "UTF-8");
String chiWord = response;
Log.println("翻译结果: " + chiWord);
System.out.print("请输入英文单词: ");
}
// 4. 关闭 socket
socket.close();
}
}
UDP服务端:
// 提供翻译的服务器
public class TranslateServer {
// 公开的 ip 地址:就看进程工作在哪个 ip 上
// 公开的 port:需要程序中指定
public static final int PORT = 8888;
// SocketException -> IOException -> Exception
public static void main(String[] args) throws Exception {
Log.println("准备进行字典的初始化");
initMap();
Log.println("完成字典的初始化");
Log.println("准备创建 UDP socket,端口是 " + PORT);
DatagramSocket socket = new DatagramSocket(PORT);
Log.println("UDP socket 创建成功");
// 作为服务器,是被动的,循环的进行请求-响应周期的处理
// 等待请求,处理并发送响应,直到永远
while (true) {
// 1. 接收请求
byte[] buf = new byte[1024]; // 1024 代表我们最大接收的数据大小(字节)
DatagramPacket receivedPacket = new DatagramPacket(buf, buf.length);
Log.println("准备好接收 DatagramPacket,最大大小为: " + buf.length);
Log.println("开始接收请求");
socket.receive(receivedPacket); // 这个方法就会阻塞(程序执行到这里就不动了,直到有客户发来请求,才能继续)
Log.println("接收到请求");
// 2. 一旦走到此处,一定是接收到请求了,拆信
// 拆出对方的 ip 地址
InetAddress address = receivedPacket.getAddress();
Log.println("对方的 IP 地址: " + address);
// 拆出对方的端口
int port = receivedPacket.getPort();
Log.println("对方的 port: " + port);
// 拆出对方的 ip 地址 + port
SocketAddress socketAddress = receivedPacket.getSocketAddress();
Log.println("对象的完整地址: " + socketAddress);
// 拆出对方发送过来的数据,其实这个 data 就是我们刚才定义的 buf 数组
byte[] data = receivedPacket.getData();
Log.println("接收到的对象的数据: " + Arrays.toString(data));
// 拆出接收到的数据的大小(字节)
int length = receivedPacket.getLength();
Log.println("接收的数据大小(字节):" + length);
// 3. 解析请求 :意味着我们需要定义自己的应用层协议
// 首先,做字符集解码 byte[] -> String
String request = new String(data, 0, length, "UTF-8");
// 这个按照我们的应用层协议
String engWord = request;
Log.println("请求(英文单词):" + engWord);
// 4. 执行业务(翻译服务),不是我们本次演示的重点
String chiWord = translate(engWord);
Log.println("翻译后的结果:" + chiWord);
// 5. 按照应用层协议,封装响应
String response = chiWord;
// 进行字符集编码 String -> byte[]
byte[] sendBuf = response.getBytes("UTF-8");
// 6. 发送响应
// 作为发送方需要提供
DatagramPacket sentPacket = new DatagramPacket(
sendBuf, 0, sendBuf.length, // 要发送的数据
socketAddress // 从请求信封中拆出来的对象的地址(ip + port)
);
Log.println("准备好发送 DatagramPacket 并发送");
socket.send(sentPacket);
Log.println("发送成功");
// 7. 本次请求-响应周期完成,继续下一次请求-响应周期
}
// socket.close(); // 由于我们是死循环,这里永远不会走到
}
private static final HashMap<String, String> map = new HashMap<>();
private static void initMap() {
map.put("apple", "苹果");
map.put("pear", "梨");
map.put("orange", "橙子");
}
private static String translate(String engWord) {
String chiWord = map.getOrDefault(engWord, "查无此单词");
return chiWord;
}
}
自定义的日志类(记得导入此类):
public class Log {
public static void println(Object o) {
LocalDateTime localDateTime = LocalDateTime.now(ZoneId.of("Asia/Shanghai"));
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
String now = formatter.format(localDateTime);
String message = now + ": " + (o == null ? "null" : o.toString());
System.out.println(message);
}
public static void main(String[] args) {
println(1);
}
}
四、TCP数据报套接字编程
4.1 Java流套接字通信模型
4.2 ServerSocket API
ServerSocket
是创建TCP服务端Socket的API。
4.2.1 ServerSocket
构造方法:
服务器使用的TCP Socket对象(传入的端口,就是要公开的端口,一般称为监听(listen)端口)
4.2. ServerSocket
普通方法
注意:
-
accept:接起电话(服务器是电话铃响的这一方)
-
Socket对象:建立起的连接
-
close:挂电话(谁都可以挂)
4.3 Socket API
Socket 是客户端Socket,或服务端中接收到客户端建立连接(accept方法)的请求后,返回的服务端Socket。
不管是客户端还是服务端Socket,都是双方建立连接以后,保存的对端信息,及用来与对方收发数据的。
4.3.1 Socket
构造方法:
注意:
- 服务器的Socket对象是从accept()中获取到的,所以,只有客户端的Socket对象需要手动实例化出来,这个构造方法是给客户端使用,传入服务器的ip+port
- 一旦socket对象拿到(双方是同时拿到的),双方就地位平等了,只区分发送方和接收方即可
4.3.2 Socket
普通方法:
注意:
- 输入流:站在进程角度,背后对象就是网卡,网卡抽象出来的TCP连接,所以是给接收方使用
- 输出流:同理,所以是给发送方使用
4.4 TCP中的长短连接
TCP发送数据时,需要先建立连接,什么时候关闭连接就决定是短连接还是长连接:
- 短连接:每次接收到数据并返回响应后,都关闭连接,即是短连接。也就是说,短连接只能一次收发数据。
- 长连接:不关闭连接,一直保持连接状态,双方不停的收发数据,即是长连接。也就是说,长连接可以多次收发数据。
对比以上长短连接,两者区别如下:
- 建立连接、关闭连接的耗时:短连接每次请求、响应都需要建立连接,关闭连接;而长连接只需要第一次建立连接,之后的请求、响应都可以直接传输。相对来说建立连接,关闭连接也是要耗时的,长连接效率更高。
- 主动发送请求不同:短连接一般是客户端主动向服务端发送请求;而长连接可以是客户端主动发送请求,也可以是服务端主动发。
- 两者的使用场景有不同:短连接适用于客户端请求频率不高的场景,如浏览网页等。长连接适用于客户端与服务端通信频繁的场景,如聊天室,实时游戏等。
扩展了解:
基于BIO(同步阻塞IO)的长连接会一直占用系统资源。对于并发要求很高的服务端系统来说,这样的消耗是不能承受的。
由于每个连接都需要不停的阻塞等待接收数据,所以每个连接都会在一个线程中运行。
一次阻塞等待对应着一次请求、响应,不停处理也就是长连接的特性:一直不关闭连接,不停的处理请求。
实际应用时,服务端一般是基于NIO(即同步非阻塞IO)来实现长连接,性能可以极大的提升。
现在还遗留一个问题:
如果同时多个长连接客户端,连接该服务器,能否正常处理?
需要在IDEA配置客户端支持同时运行多个实例!
- 短连接客户端 <–> 短连接服务器 支持同时在线
- 短连接客户端 <-> 长连接服务器 支持同时在线
- 长连接客户端 <-> 长连接服务器 不支持同时在线
所以可以使用多线程解决长连接客户端不支持同时在线的问题:
将任务专门交给其他线程来处理,主线程只负责接受socket。
4.5 代码示例(短连接)
这里仅演示短连接,长连接和多线程在博主的个人仓库下:
网络开发代码
TCP服务端:
public class TranslateServerShortConnection {
public static final int PORT = 8888;
public static void main(String[] args) throws Exception {
Log.println("启动短连接版本的 TCP 服务器");
initMap();
ServerSocket serverSocket = new ServerSocket(PORT);
while (true) {
// 接电话
Log.println("等待对方来连接");
Socket socket = serverSocket.accept();
Log.println("有客户端连接上来了");
// 对方信息:
InetAddress inetAddress = socket.getInetAddress(); // ip
Log.println("对方的 ip: " + inetAddress);
int port = socket.getPort(); // port
Log.println("对方的 port: " + port);
SocketAddress remoteSocketAddress = socket.getRemoteSocketAddress(); // ip + port
Log.println("对方的 ip + port: " + remoteSocketAddress);
// 读取请求
InputStream inputStream = socket.getInputStream();
Scanner scanner = new Scanner(inputStream, "UTF-8");
String request = scanner.nextLine(); // nextLine() 就会去掉换行符
String engWord = request;
Log.println("英文: " + engWord);
// 翻译
String chiWord = translate(engWord);
Log.println("中文: " + chiWord);
// 发送响应
String response = chiWord; // TODO: 响应的单词中是没有 rn
OutputStream outputStream = socket.getOutputStream();
OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputStream, "UTF-8");
PrintWriter writer = new PrintWriter(outputStreamWriter);
Log.println("准备发送");
writer.printf("%srn", response);
writer.flush();
Log.println("发送成功");
// 挂掉电话
socket.close();
Log.println("挂断电话");
}
// serverSocket.close();
}
private static final HashMap<String, String> map = new HashMap<>();
private static void initMap() {
map.put("apple", "苹果");
map.put("pear", "梨");
map.put("orange", "橙子");
}
private static String translate(String engWord) {
String chiWord = map.getOrDefault(engWord, "查无此单词");
return chiWord;
}
}
TCP客户端:
public class UserInputLoopShortConnectionClient {
public static void main(String[] args) throws Exception {
Scanner userInputScanner = new Scanner(System.in);
while (true) {
// 这里做了一个假设:1)用户肯定有输入 2)用户一行一定只输入一个单词(没有空格)
System.out.print("请输入英文单词: ");
if (!userInputScanner.hasNextLine()) {
break;
}
String engWord = userInputScanner.nextLine();
// 直接创建 Socket,使用服务器 IP + PORT
Log.println("准备创建 socket(TCP 连接)");
Socket socket = new Socket("127.0.0.1", TranslateServerShortConnection.PORT);
Log.println("socket(TCP 连接) 创建成功");
// 发送请求
Log.println("英文: " + engWord);
String request = engWord + "rn";
OutputStream os = socket.getOutputStream();
OutputStreamWriter osWriter = new OutputStreamWriter(os, "UTF-8");
PrintWriter writer = new PrintWriter(osWriter);
Log.println("发送请求中");
writer.print(request);
writer.flush();
Log.println("请求发送成功");
// 等待接受响应
InputStream is = socket.getInputStream();
Scanner socketScanner = new Scanner(is, "UTF-8");
// 由于我们的响应一定是一行,所以使用 nextLine() 进行读取即可
// nextLine() 返回的数据中,会自动把 rn 去掉
// TODO: 没有做 hasNextLine() 的判断
Log.println("准备读取响应");
String chiWord = socketScanner.nextLine();
Log.println("中文: " + chiWord);
socket.close();
}
}
}
五、 关于输入流和输出流的使用
5.1 关于输入流的使用:
- 如果直接进行二进制读取
byte[] buf = new byte[1024];
int n = inputStream.read(buf);
- 如果读取文本数据,建议直接使用Scanner封装InputStream后再使用
Scanner S = new Scanner(inputStream,"UTF-8");
s.nextLine() ... s.hasNextLine()
5.2 关于输出流的使用:
- 如果直接进行二进制输出
outputStream.write(buf,offset,length)
- 如果是文本输出,建议OutputStream -> OutputStreamWriter -> PrintWriter
OutputStreamWriter osWriter = new OutputStreamWriter(outputStream,"UTF-8");
PrintWriter writer = new PrintWriter(osWriter);
writer.println(...);
writer.print(...);
writer.printf(format,...);
重要:不要忘记刷新缓冲区,否则数据可能无法到达对方!!!
outputStream.flush();
//writer.flush();
六、面向数据报文VS面向字节流
举个栗子:
总结
关于端口被占用的问题:
如果一个进程A已经绑定了一个端口,再启动一个进程B绑定该端口,就会报错,这种情况也叫端口被占用。对于java进程来说,端口被占用的常见报错信息如下:
此时需要检查进程B绑定的是哪个端口,再查看该端口被哪个进程占用。以下为通过端口号查进程的方式:
-
在cmd输入 netstat -ano | findstr 端口号 ,则可以显示对应进程的pid。如以下命令显
示了8888进程的pid
-
在任务管理器中,通过pid查找进程
解决端口被占用的问题:
- 如果进程没啥用,就可以把进程杀掉
- 如果进程不确定,可以换个端口使用
最后
以上就是美丽小蝴蝶为你收集整理的Socket套接字(网络编程万字总结-附代码)前言一、概念二、分类(三类)三、UDP数据报套接字编程四、TCP数据报套接字编程五、 关于输入流和输出流的使用六、面向数据报文VS面向字节流总结的全部内容,希望文章能够帮你解决Socket套接字(网络编程万字总结-附代码)前言一、概念二、分类(三类)三、UDP数据报套接字编程四、TCP数据报套接字编程五、 关于输入流和输出流的使用六、面向数据报文VS面向字节流总结所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复