【发布时间】：2011-09-26 08:41:07
【问题描述】：
我正在尝试使用 java UDP 协议将数据包从一台主机发送到另一台对等主机。
一台主机发送数据，而另一台主机读取数据。然而，相应的读取一直阻塞，因此没有接收到数据。我可以使用wireshark看到发送方数据包到达正确的目的地，但接收方不会接收它。读取操作无限期地阻塞。
请帮忙。 cient代码：
//CLIENT CLASS
//Sections ommited....
DatagramSocket so = new DatagramSocket(port);
protected void send(byte[] buffer,int packetsize){
DatagramPacket p;
try {
myClient.notifyInform("Sending data to "+inetaddress+" on"+port+"\n");
p=new DatagramPacket(buffer,buffer.length,InetAddress.getByName(inetaddress),port);
writeLock.lock();
try{
so.send(p);
}finally{
writeLock.unlock();
}
} catch (UnknownHostException e) {
myClient.perror("Could not connect to peer:"+e.getMessage()+"\n");
e.printStackTrace();
} catch (IOException e) {
myClient.perror("IOException while sending to peer.\n");
e.printStackTrace();
}
}
protected DatagramPacket read(){
byte[] buf=new byte[bufsize];
DatagramPacket p=new DatagramPacket(buf,buf.length);//TODO check these values, what should buffer be? just made it psize*10 for now
readLock.lock();
try{
myClient.notifyInform("receiving data\n");
so.receive(p);
this.myclient.notifyInform(String.valueOf(p.getData().length)+"\n");
} catch (IOException e) {
myClient.perror("IOException while reading from peer.\n");
e.printStackTrace();
}finally{
readLock.unlock();
}
return p;
}
protected void beginRead() {
while(active) {
System.out.println("########################");
byte[] data=this.read().getData();
myClient.notifyInform("Receiving data\n");
}
}
protected void beginSend(){
forkWork(new Runnable(){
@Override
public void run() {
byte[] sendBuffer=new byte[bufsize];
int cnt;
while(callActive){
try{
sourceLock.lock();
cnt=dataSource.read(sendBuffer, 0, bufsize);
}finally{
sourceLock.unlock();
}
if (cnt >0) {
send(sendBuffer, packetsize);
}
}
}
});
}
更新：我犯了一个错误，我终于找到了。绑定端口并修复该错误后，它现在可以工作了。
【问题讨论】：
-
防火墙能阻止它吗？你使用什么特别的东西，比如多播地址？
-
不，我关闭了所有防火墙，并且没有使用多播。
-
两种简单的可能性：其他东西已经绑定了该端口，或者您在 Unix/Linux 平台上并尝试绑定小于 1024 的端口号而不是 root。