上一篇的兄弟篇
上一篇地址:https://www.jianshu.com/p/457b24e5e0a5
基于UDP
UDP协议以数据包作为数据传输的载体,也就是在数据传输时,我们需要将数据包装成数据报,在数据报中指明目的主机地址和端口号,然后将数据报发出去,用到了两个关键类:
- DatagramPacket 数据报包
- DatagramSocket 进行端到端通信的类
服务器
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
new Thread(){
@Override
public void run() {
try {
//步骤①创建服务器端DatagramSocket,指定端口
DatagramSocket socket = new DatagramSocket(8899);
//步骤②创建数据报,用于接收客户端发送的数据
byte[] data =new byte[1024];//创建字节数组,指定接收的数据包的大小
DatagramPacket packet=new DatagramPacket(data, data.length);
//步骤③接收客户端发送的数据
System.out.println("server loaded success,waiting...");
socket.receive(packet);//此方法在接收到数据报之前会一直阻塞
//步骤④读取数据
String info=new String(data, 0, packet.getLength());
//为了简单起见,这里就不再写验证的逻辑了
//步骤⑤定义客户端的地址、端口号、数据
InetAddress address=packet.getAddress();
int port=packet.getPort();
byte[] data2="Welcome!!!".getBytes();
//步骤⑥创建数据报,包含响应的数据信息
DatagramPacket packet2=new DatagramPacket(data2, data2.length, address, port);
//步骤⑦响应客户端
socket.send(packet2);
//步骤⑧关闭资源
socket.close();
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
}
客户端
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
new Thread(){
@Override
public void run() {
//步骤①定义服务器的地址、端口号、数据
InetAddress address= null;
try {
address = InetAddress.getByName("localhost");
} catch (UnknownHostException e) {
e.printStackTrace();
}
int port=8899;
byte[] data="admin:123".getBytes();
//步骤②创建数据报,包含发送的数据信息
DatagramPacket packet=new DatagramPacket(data, data.length, address, port);
try {
//步骤③创建DatagramSocket对象
DatagramSocket socket = new DatagramSocket();
//步骤④向服务器端发送数据报
socket.send(packet);
//步骤⑤创建数据报,用于接收服务器端响应的数据
byte[] data2=new byte[1024];
DatagramPacket packet2=new DatagramPacket(data2, data2.length);
//步骤⑥接收服务器响应的数据
socket.receive(packet2);
//步骤⑦读取数据
String reply=new String(data2, 0, packet2.getLength());
System.out.println("server reply : "+reply);
//步骤⑧关闭资源
socket.close();
} catch (SocketException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
}