我正在为android编写一个java套接字程序:
DeviceManagerWindow.java
public class DeviceManagerWindow extends Activity
{
Thread sendMulticast;
...
...
WifiManager wifi = (WifiManager)getSystemService( Context.WIFI_SERVICE );
if(wifi != null)
{
WifiManager.MulticastLock lock = wifi.createMulticastLock("WifiDevices");
lock.acquire();
}
public void searchDevice(View view)
{
sendMulticast = new Thread(new MultiCastThread());
sendMulticast.start();
ExecutorService executorService = Executors.newFixedThreadPool(1);
List<Future<DeviceDetails>> deviceList = new ArrayList<Future<DeviceDetails>>();
Callable<DeviceDetails> device = new MulticastReceiver();
Future<DeviceDetails> submit = executorService.submit(device);
deviceList.add(submit);
DeviceDetails[] devices = new DeviceDetails[deviceList.size()];
int i=0;
for(Future<DeviceDetails> future :deviceList)
{
try
{
devices[i] = future.get();
}
catch(Exception e)
{
Log.v("future Exception: ",e.toString());
}
}
listAllDevices(devices);
}
}
在接收器类中,我有以下代码:
MultivastReceiver.java
public class MulticastReceiver implements Callable<DeviceDetails>
{
DatagramSocket socket = null;
DatagramPacket inPacket = null;
public MulticastReceiver()
{
try
{
socket = new DatagramSocket(5500);
}
catch(Exception ioe)
{
System.out.println(ioe);
}
}
@Override
public DeviceDetails call() throws Exception
{
// TODO Auto-generated method stub
try
{
byte[] inBuf = new byte[WifiConstants.DGRAM_LEN];
//System.out.println("Listening");
inPacket = new DatagramPacket(inBuf, inBuf.length);
socket.receive(inPacket);
String msg = new String(inBuf, 0, inPacket.getLength());
Log.v("Received: ","From :" + inPacket.getAddress() + " Msg : " + msg);
DeviceDetails device = getDeviceFromString(msg);
return device;
}
catch(Exception e)
{
Log.v("Receiving Error: ",e.toString());
return null;
}
}
public DeviceDetails getDeviceFromString(String str)
{
String type;
String IP;
type=str.substring(0,str.indexOf('`'));
str = str.substring(str.indexOf('`')+1);
IP=str;
DeviceDetails device = new DeviceDetails(type,IP);
return device;
}
}
现在,上面的代码只搜索第一个数据包,当它收到第一个数据包时,它会停止搜索下一个数据包。我希望它监听传入数据包 30 秒,然后退出,并保留收到的所有数据。如何做到这一点。
如果我使用无限循环,那么它将永远不会返回该值,因为 return 语句将放置在循环之外,如果我将 return 语句放在循环内,它将返回值并且永远不会等待下一个数据包来吧。
最佳答案
有两种可能性。
您可以将套接字设置为 30 秒后超时。不幸的是,每次您收到新消息时,这都会重置。因此,如果您知道所有消息将在 30 秒内到达,只需设置超时,套接字最终将在收到最后一个数据包后超时。
第二个选项是使用单独的 TimerTask 来唤醒您的客户端,这样它就不会无限期地阻塞在接收中。您将需要从应该完成这项工作的计时器任务中断客户端线程。
在这两种情况下,您都需要处理适当的异常来处理超时。
关于java - Socket监听多个数据包,没有无限循环,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15903240/