javasocket无端口_听说你还不会Socket编程！

作者&＃xff1a;zskingking

博客&＃xff1a;https://www.jianshu.com/p/b04930d2b85e

上周我们描述了传输层协议TCP、UDP&＃xff0c;但它们毕竟只是协议&＃xff0c;看不见摸不着&＃xff0c;那我们怎们通过TCP、和UDP进行实际传输呢&＃xff1f;不用着急&＃xff0c;等看完这篇文章你一定会明白的。

Socket概述

Socket中文意思为插座的意思&＃xff0c;专业术语称之为套接字&＃xff0c;它把TCP/IP封装成了调用接口供开发者调用&＃xff0c;也就是说开发者可以通过调用Socket相关API来实现网络通讯。在Java中也存在Socket相关API&＃xff0c;主要分为两个&＃xff0c;分别是基于UDP传输协议的Socket和基于TCP传输协议的Socket&＃xff0c;本篇文章会对基于这两种传输协议的Socket进行详细描述。

UDP Socket

通过上节的内容我们知道UDP是无连接的&＃xff0c;只要提供对方的IP地址和端口号就能进行数据的传输&＃xff0c;其中IP负责定位主机端口负责定位应用。知道了目标IP和目标端口号通过Java中的UDP Socket就能进行IO传输&＃xff0c;我们来看一下具体的代码体现

**
* 发送方UDP
*/
public class UDPSocketSend {
public static void main(String[] args) throws IOException {

System.out.println("Sender Start...");

//1.创建socket服务
DatagramSocket ds &＃61; new DatagramSocket;

//2.封装数据
String str &＃61; "Did you recite words today";
byte bytes &＃61; str.getBytes;
//地址
InetAddress address &＃61;InetAddress.getByName("192.168.31.137");
//参数&＃xff1a;数据、长度、地址、端口
DatagramPacket dp &＃61; new DatagramPacket(bytes,bytes.length,address,6666);

//3.发送数据包
ds.send(dp);

//4.关闭socket服务
ds.close;
}

/**
* 接收方UDP
*/
public class UDPSocketReceive{
public static void main(String[] args) throws IOException {

System.out.println("Receiver Start...");

//1.创建udp的socket服务,并声明端口号
DatagramSocket ds &＃61; new DatagramSocket(6666);

//2.创建接收数据的数据包
byte bytes &＃61; new byte[1024];
DatagramPacket dp &＃61; new DatagramPacket(bytes,bytes.length);

//3.将数据接收到数据包中&＃xff0c;为阻塞式方法
ds.receive(dp);

//4.解析数据
InetAddress address &＃61; dp.getAddress;//发送方IP
int port &＃61; dp.getPort;//发送方端口
String content &＃61; new String(dp.getData,0,dp.getLength);
System.out.println("address:"&＃43;address&＃43;"---port:"&＃43;port&＃43;"---content:"&＃43;content);

//关闭服务
ds.close;
}
}

分别启动发送方和接收方&＃xff0c;我们来看一下打印结果

发送方&＃xff1a;

Sender Start...

接收方&＃xff1a;

Receiver Start...
address:/192.168.31.137---port:65037---content:Did you recite words today

成功接收到消息&＃xff0c;并打印出发送方IP和端口&＃xff0c;下面我来个大家撸一遍步骤

发送方&＃xff1a;

• 首先创建udp的socket服务

• 将需要发送的数据放在数据包DatagramSocket中&＃xff0c;DatagramSocket会根据UDP协议对数据包、IP、端口号进行封装

• 通过udp的socket服务将数据包发送

• 最后将udp服务关闭

接收方&＃xff1a;

• 创建udp的socket服务&＃xff0c;并且明确自己的端口号

• 创建DatagramSocket用来解析数据接收到的数据包

• 将数据接收到数据包DatagramSocket中

• 通过DatagramSocket解析数据

• 关闭服务

整个UDP发送数据的流程就是这样

注意点&＃xff1a;

• 为UDP是无连接的不可靠传输&＃xff0c;所以接收方需要在发送方发送数据之前就启动&＃xff0c;否则会接收不到数据&＃xff0c;也就是说必须先运行UDPSocketReceive再运行UDPSocketSend。

聊天实例

把上面的例子进行一些小改动就可以实现聊天功能

public class UDPSocket1 {
public static void main(String[] args) {
try {
new Thread(new Runnable {
&＃64;Override
public void run {
try {
receive;
} catch (IOException e) {
e.printStackTrace;
}
}
}).start;
send;
} catch (IOException e) {
e.printStackTrace;
}
}

//接收消息方法
private static void receive throws IOException {
System.out.println("UDOSocket1 Receiver Start...");

//1.创建udp的socket服务,并声明端口号
DatagramSocket ds &＃61; new DatagramSocket(6666);
//无限循环&＃xff0c;一直处于接收状态
while (true) {
//2.创建接收数据的数据包
byte bytes &＃61; new byte[1024];
DatagramPacket dp &＃61; new DatagramPacket(bytes, bytes.length);

//3.将数据接收到数据包中
ds.receive(dp);

//4.解析数据
String content &＃61; new String(dp.getData, 0, dp.getLength);
System.out.println("UDPSocket1 Receive:" &＃43; content);
}
}

private static void send throws IOException {
//1.创建socket服务
DatagramSocket ds &＃61; new DatagramSocket;

//将键盘输入的信息转换成输入流再放入到缓冲区
BufferedReader br &＃61; new BufferedReader(new InputStreamReader(System.in));
String line &＃61; ;
while ((line&＃61;br.readLine)!&＃61;){
//2.封装数据
byte bytes &＃61; line.getBytes;
//地址
InetAddress address &＃61;InetAddress.getByName("192.168.31.137");
//参数&＃xff1a;数据、长度、地址、端口
DatagramPacket dp &＃61; new DatagramPacket(bytes,bytes.length,address,7777);

//3.发送数据包
ds.send(dp);
}

//4.关闭socket服务
ds.close;
}
}

public class UDPSocket2 {
public static void main(String[] args){
try {
new Thread(new Runnable {
&＃64;Override
public void run {
try {
receive;
} catch (IOException e) {
e.printStackTrace;
}
}
}).start;
send;
} catch (IOException e) {
e.printStackTrace;
}
}

//接收消息方法
private static void receive throws IOException {
System.out.println("UDOSocket2 Receiver Start...");

//1.创建udp的socket服务,并声明端口号
DatagramSocket ds &＃61; new DatagramSocket(7777);
//无限循环&＃xff0c;一直处于接收状态
while (true) {
//2.创建接收数据的数据包
byte bytes &＃61; new byte[1024];
DatagramPacket dp &＃61; new DatagramPacket(bytes, bytes.length);

//3.将数据接收到数据包中
ds.receive(dp);

//4.解析数据
String content &＃61; new String(dp.getData, 0, dp.getLength);
System.out.println("UDPSocket2 Receive:" &＃43; content);
}
//关闭服务
// ds.close;
}

private static void send throws IOException {
//1.创建socket服务
DatagramSocket ds &＃61; new DatagramSocket;

//将键盘输入的信息转换成输入流再放入到缓冲区
BufferedReader br &＃61; new BufferedReader(new InputStreamReader(System.in));
String line &＃61; ;
while ((line&＃61;br.readLine)!&＃61;){
//2.封装数据
byte bytes &＃61; line.getBytes;
//地址
InetAddress address &＃61;InetAddress.getByName("192.168.31.137");
//参数&＃xff1a;数据、长度、地址、端口
DatagramPacket dp &＃61; new DatagramPacket(bytes,bytes.length,address,6666);

//3.发送数据包
ds.send(dp);
}

//4.关闭socket服务
ds.close;
}
}

在接收方方法写一个无限循环让其处于持续接收状态&＃xff0c;发送发通过对键盘录入加回车进行消息的发送&＃xff0c;并且两个端点都具备发送和接收功能。需要注意的是receive会执行一个无限循环&＃xff0c;所以receive和send必须位于不同线程&＃xff0c;否则会导致无法发送消息从而也接收不到消息。

来看打印结果&＃xff1a;UDPSocket1

UDPSocket Receiver Start...
UDPSocket Receive:hello udp1
heelo udp2

UDPSocket2

UDPSocket2 Receiver Start...
hello udp1
UDPSocket2 Receive:hello udp2

我在UDPSocket1 的控制台中输入了&＃xff1a;“hello udp2”、在UDPSocket2 的控制台中输入了&＃xff1a;“hello udp1”&＃xff0c;接收内容和发送内容完全一致&＃xff0c;一个简单的聊天功能就实现了&＃xff0c;希望不熟悉的朋友也可以敲一遍代码练一遍。

TCP Socket

TCP基于client-server是面向连接的可靠传输&＃xff0c;上篇文章我们也讲解了TCP安全传输机制&＃xff0c;可谓是相当复杂&＃xff0c;如果需要个人对TCP协议进行封装显然大多数开发者是很难实现的&＃xff0c;所以Java也为开发者提供了基于TCP的Socket&＃xff0c;不同于UDP&＃xff0c;TCP Socket分为Socket和ServerSocket对应着client和server&＃xff0c;下面我来用代码实现一个简单的TCP通讯功能&＃xff1a;

客户端&＃xff1a;

//客户端
public class TCPClient {
public static void main(String[] args) throws IOException {

//1.创建TCP客户端Socket服务
Socket client &＃61; new Socket;
//2.与服务端进行连接
InetSocketAddress address &＃61; new InetSocketAddress("192.168.31.137