2

我正在开发一个 Android 应用程序。

这个应用程序将有一个服务器来启动一个 DatagramSocket 作为服务器。它将等待传入消息。当套接字收到消息时，我将处理它。

要启动 UDP 服务器套接字，我将使用本地服务。该服务将有一个工作线程，我将在其中收听传入的消息。

这是我未完成的本地服务实现：

public class UDPSocketBackgroundService extends Service
{
    private static final String TAG = "UDPSocketBackgroundService";
    private ThreadGroup myThreads = new ThreadGroup("UDPSocketServiceWorker");
    private Handler mServiceHandler;

    @Override
    public void onCreate()
    {
        super.onCreate();
        Log.v(TAG, "in onCreate()");
    }

    @Override
    public IBinder onBind(Intent arg0)
    {
        try
        {
            new Thread(myThreads, new UDPServerThread("X", 8888)).start();
        }
        catch (IOException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }
}

这也是我未完成的Worker Thread 实现：

public class UDPServerThread extends Thread
{
    private static final int MESSAGE_SIZE = 256;

    protected DatagramSocket socket = null;
    protected boolean end = false;

    public UDPServerThread(String serverName, int port) throws IOException
    {
        super(serverName);
        socket = new DatagramSocket(port);
    }

    public void run()
    {
        while (!end)
        {
            try
            {
                byte[] buf = new byte[MESSAGE_SIZE];

                // Wait an incoming message.
                DatagramPacket packet = new DatagramPacket(buf, buf.length);
                socket.receive(packet);
                // TODO: Notify Service with packet received
            }
            catch (IOException e)
            {
                // TODO Mensaje de error.
                e.printStackTrace();
            }
        }
    }
}

这些类有自己的文件（它们位于不同的文件中）。

这里：

socket.receive(packet);
//TODO: Notify Service with packet received

如何通知服务我们已收到数据包？我也想发送该数据包以提供服务。

这里有一个关于如何从主线程到工作线程进行通信的示例。但是，我不需要那个，我正在寻找一个关于如何从工作线程到服务进行通信的示例。

我找到了这个例子，但我不太了解它，因为在那个例子中，两个类都在同一个文件中声明它。

如您所见，我是 Android 开发的新手。

如果您知道更好的方法，请告诉我。

4

1 回答 1

0

创建 UDPServerThread 时，可以传入对 UDPSocketBackgroundService 的引用，然后在收到数据包时调用它的方法（例如 processPacket()）。这个 processPacket() 方法需要使用某种同步。

以下是相关函数的一小段代码摘录：

public class UDPSocketBackgroundService extends Service
{
    ....
    @Override
    public IBinder onBind(Intent arg0)
    {
        try
        {
            new Thread(myThreads, new UDPServerThread(this, "X", 8888)).start();
            // Notice we're passing in a ref to this  ^^^
        }
        ...
    }
    public void processPacket(DatagramPacket packet)
    {
        // Do what you need to do here, with proper synchronization
    }
}

public class UDPServerThread extends Thread
{
    private static final int MESSAGE_SIZE = 256;

    protected DatagramSocket socket = null;
    protected boolean end = false;
    protected UDPSocketBackgroundService = null;

    public UDPServerThread(UDPSocketBackgroundService service, String serverName, int port) throws IOException
    {
        super(serverName);
        this.service = service;
        socket = new DatagramSocket(port);
    }

    ...

    public void run()
    {
        while (!end)
        {
            try
            {
                byte[] buf = new byte[MESSAGE_SIZE];

                // Wait an incoming message.
                DatagramPacket packet = new DatagramPacket(buf, buf.length);
                socket.receive(packet);
                service.processPacket(packet);
            }
            ...
        }
        ...
    }
}

请注意，采用这种方法，UDPSocketBackgroundService 现在与 UDPServerThread “紧密耦合”。一旦你得到这个工作，你可以考虑用一个更优雅的设计来重构它，减少耦合，但现在这应该让你开始:)

于 2012-06-11T10:23:35.247 回答