【发布时间】:2017-12-10 07:39:28
【问题描述】:
我正在自学 Android 和 Java 编程。为了练习,我开发了几个应用程序,现在我正在尝试编写一个类似聊天的应用程序。所以基本上,我想要像 WhatsApp 这样的东西。我有一个服务器程序也由我在我的计算机上运行,它是 Android 系统中的聊天用来通信的。因此,基本上,所有内容都发送到服务器,服务器执行传递消息所需的操作。
所以这就是我所拥有的:
- 首先,我的应用向我的服务器发送一个“Hello”(已知 IP 和端口)
- 服务器存储每个用户使用的 IP 和端口(也是用户名)
当要求服务器向用户传递消息时,它会将消息发送到存储的 IP 和端口
我为“Hello”使用了一个套接字,但我不能使用同一个套接字来发回消息(因为我对服务器进行了编程)。但这不是问题。当服务器收到“Hello”时,它正在侦听相应的端口。但是当服务器是必须启动连接的人时,应用程序就是必须的人。为了做到这一点,应用程序必须知道它必须监听哪个端口(由于 NAT,它不知道),我告诉它,通过用于“Hello”消息的第一个套接字发回使用的端口。尽管如此,我的应用还是无法接收消息并停留在接收呼叫中。
这里有代码:
服务器:
DatagramSocket client = new DatagramSocket(2048); //Predefined port
DatagramPacket receivePacket;
byte[] receiveData = new byte[1024];
receivePacket = new DatagramPacket(receiveData,
receiveData.length);
System.out.println("Ready to receive");
client.receive(receivePacket);
System.out.println("Received successfuly");
String receivedPort = String.valueOf(receivePacket.getPort());
byte[] sendData = receivedPort.getBytes();
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, receivePacket.getAddress(), receivePacket.getPort());
client.send(sendPacket); //Send back the port used by the app
System.out.println("Sent successfuly");
client.close();
Thread.sleep(1000); //To make sure the app is ready to listen
DatagramSocket socket = new DatagramSocket();
byte[] sendData2 = "Working like a charm".getBytes();
InetAddress ip = receivePacket.getAddress();
int port = receivePacket.getPort();
System.out.println(ip + " " + port);
DatagramPacket sendPacket2 = new DatagramPacket(sendData2, sendData2.length, ip, port);
socket.send(sendPacket);
System.out.println("Sent successfuly 2nd time");
socket.close();
客户端(Android 应用):
EditText eT = (EditText) findViewById(R.id.messageText);
String message = eT.getText().toString();
DatagramSocket socket = new DatagramSocket();
byte[] sendData = message.getBytes();
InetAddress ip = InetAddress.getByName(MY_COMPUTER'S_IP);
DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, ip, 2048);
socket.send(sendPacket);
byte[] receiveData = new byte[1024];
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
socket.receive(receivePacket); //Receive the port used (and that must be opened and redirecting the traffic to this device due to NAT)
socket.close();
String receivedMessage = new String(receivePacket.getData());
String receivedData = new String(receivePacket.getData());
String actualData = receivedData.substring(0, receivePacket.getLength());
Log.d("Port", actualData);
int port = Integer.parseInt(actualData);
DatagramSocket socket2 = new DatagramSocket(port);
DatagramPacket receivePacket2;
byte[] receiveData2 = new byte[1024];
receivePacket2 = new DatagramPacket(receiveData2,
receiveData2.length);
socket2.receive(receivePacket2); //Here is where it gets blocked
String data = new String(receivePacket2.getData());
Log.d("Finally received", data.substring(receivePacket2.getLength()));
socket2.close();
有人知道为什么我的消息没有通过第二个套接字返回吗?我检查了,IP 和端口是正确的。提前感谢您的回答,我为我的格式道歉。
【问题讨论】:
-
可能是防火墙阻止了通信