Singleton Bean UDP 监听器

Question

我对 Java EE 开发非常陌生，我正在尝试在 GlassFish 中创建 UDP 侦听器。这将始终需要运行。因此，我相信 Singleton bean 能够完成这项任务。

问题就在这里。该代码可以工作，但会导致 GlassFish 运行缓慢。尽管应用程序已部署，但 GlassFish 的管理页面只是挂起。我也无法访问已部署的 WAR 应用程序的其他元素，导致我相信存在线程问题。然而，我始终假设 EJB 不存在线程问题。我在 Eclipse 中做了这个。

@Singleton
@LocalBean
public class UDPListener {
    public UDPListener() 
    { 
        DatagramSocket datagramSocket = null;
    try 
    {
        datagramSocket = new DatagramSocket(9090);
    } catch (SocketException e) { e.printStackTrace(); }    

    byte[] buffer = new byte[100];

    // Create a datagram packet.
    DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

    while(true)
    {
        // Receive the packet.
        try {
            datagramSocket.receive(packet);
        } catch (IOException e) { e.printStackTrace(); }

        buffer = packet.getData();          
                // Print the data:
        System.out.println(new String(buffer));
    }
    }
}

我有什么遗漏的吗？我一直在回顾 Java EE 6 教程，它提到了一些关于并发访问的内容。但是，我不确定这是否是问题所在。

谢谢

编辑：只是为了添加更多信息，我本质上需要创建一个始终运行、侦听和响应传入的 UDP 数据包的 Bean。我该如何做以不杀死主线程的方式实例化这个bean？

Answer 1

从 DatagramSocket.receive() javadocs：

此方法会阻塞，直到收到数据报为止。

通过在无限循环 (while(true)) 中调用 accept，您会主动等待传入数据，从而阻塞系统。

编辑：
如果您的 UDP 侦听器不应阻塞主线程，则它必须在不同的线程中运行。只需使用您的侦听代码启动一个新线程，然后执行主线程中必须执行的操作即可。像这样的事情：

Thread t = new Thread(new Runnable() {

    @Override
    public void run() {
        DatagramSocket datagramSocket = null;
        try 
        {
            datagramSocket = new DatagramSocket(9090);
        } catch (SocketException e) { e.printStackTrace(); }    

        byte[] buffer = new byte[100];

        // Create a datagram packet.
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
        while(true)
        {
            // Receive the packet.
            try {
                datagramSocket.receive(packet);
            } catch (IOException e) { e.printStackTrace(); }

            buffer = packet.getData();          
                // Print the data:
            System.out.println(new String(buffer));
        }
    }
});

t.start();

//go on with main thread