java - 如何让 UDP 服务器和客户端同时监听传入和传出数据包
问题描述
我正在尝试在 Java 中实现一个简单的 UDP 连接,我希望客户端和服务器都在监听传入的消息并准备好同时发送消息。
目前,该程序使得服务器开始侦听传入的数据包,以便客户端发送第一条消息。
如果可能的话,我真的很想知道一种简单的方法来实现这一点。
这是客户端的代码:
class EchoClient
{
public static void main( String args[] ) throws Exception
{
System.out.println("\nWelcome to UDP Client");
System.out.println("---------------------------------------------------");
Scanner sc = new Scanner (System.in);
DatagramSocket socket = new DatagramSocket();
socket.setSoTimeout(120000);
while (true)
{
//Send
System.out.print("\nEnter message: ");
String msg = sc.nextLine();
byte[] buffer = msg.getBytes();
DatagramPacket packetS = new DatagramPacket(buffer,buffer.length,InetAddress.getByName(args[0]),1500);
socket.send( packetS );
//Receive
DatagramPacket packetR = new DatagramPacket(new byte[512],512);
socket.receive( packetR );
System.out.println( "Alice at: "+new Date()+" "+packetR.getAddress()+":"+packetR.getPort()+"\nSays: "+new String(packetR.getData(),0,packetR.getLength()) );
}
}
}
服务器的代码:
class EchoServer
{
public static void main( String args[] ) throws Exception
{
System.out.println("\nWelcome to UDP Server");
System.out.println("---------------------------------------------------");
Scanner sc = new Scanner (System.in);
DatagramSocket socket = new DatagramSocket(1500);
//Message loop
while ( true )
{
//Receiving
DatagramPacket packetR = new DatagramPacket(new byte[512],512);
socket.receive( packetR );
System.out.println("Bob at: "+new Date()+" "+packetR.getAddress()+":"+packetR.getPort()+"\nSays: "+new String(packetR.getData(),0,packetR.getLength()) );
//Send
System.out.print("\nEnter message: ");
String msg = sc.nextLine();
byte[] buffer = msg.getBytes();
DatagramPacket packetS = new DatagramPacket(buffer,buffer.length,packetU.getAddress(),packetU.getPort());
socket.send( packetS );
}
}
}
解决方案
您好,这样做的一种简单方法是在主线程中启动多个线程。
class EchoServerClient
{
public static void main( String args[] ) throws Exception
{
new Thread(() -> {
EchoServer.main(args) //You can also rename main by another name
}).start();
new Thread(() -> {
EchoClient.main(args) //You can also rename main by another name
}).start();
}
}
推荐阅读
- case-insensitive - Blue Prism 决策阶段忽略字母大写
- reactjs - 在 xState 操作中设置上下文并触发方法
- ios - 如何在 Swift 4 中初始化代码生成的按钮边框
- debugging - OpenCL + Intel System Studio 2019 - GPU 调试问题
- android - 在 android 中按下时更改选项卡布局的选项卡中的文本大小
- c# - 打开其他 EXCEL 文件时不加载 VSTO Excel 模板
- python - 在 tensorflow 中,如何将索引列表转换为指标向量?
- python - 如果循环为空,则显示一条消息
- php - fgets 一个 UTF-8 txt 文件返回垃圾字母,当文件为空白时返回 true
- android - Android Socket.io 后台服务