0

我在客户端-服务器实现 T_Client 中有这个客户端类“T_Client”

public class T_Client{
    private static final String TAG = "T_Client";

    private static String serverIP = "192.168.2.5";
    private static int port = 4444;
    private InetAddress serverAddr = null;
    private Socket sock = null;
    private boolean running = false;
    private ObjectInputStream in;
    private ObjectOutputStream out;
    Object objIn;    

    public void send(MessageCustom _msg) {
        if (out != null) {
            try {
                out.writeObject(_msg);
                out.flush();

                // out.close();
                Log.i("Send Method", "Outgoing : " + _msg.toString());
            } catch (IOException ex) {
                Log.e("Send Method", ex.toString());
            }
        }
    }

    public void stopClient() {
        running = false;
    }

    public void run() {
        running = true;
        try {
            // here you must put your computer's IP address.
            serverAddr = InetAddress.getByName(serverIP);

            Log.i("TCP Client", "C: Connecting...");

            // create a socket to make the connection with the server
            sock = new Socket(serverAddr, port);

            try {

                // send the message to the server
                out = new ObjectOutputStream(sock.getOutputStream());

                // receive the message which the server sends back
                in = new ObjectInputStream(sock.getInputStream());

                Log.i("TCP Client", "C: Connected.");

                // in this while the client listens for the messages sent by the
                // server
                while (running) {
                    objIn = in.readObject();

                    Log.i("Object Read", objIn.toString());

                }

                Log.e("RESPONSE FROM SERVER", "S: Received Message: '" + objIn
                        + "'");

            } catch (Exception e) {

                Log.e("TCP", "S: Error", e);

            } finally {
                // the socket must be closed. It is not possible to reconnect to
                // this socket
                // after it is closed, which means a new socket instance has to
                // be created.
                out.close();
                in.close();
                sock.close();
                Log.i(TAG, "Closing socket: " + sock);
            }

        } catch (Exception e) {

            Log.e("TCP", "C: Error", e);

        }

    }

}

我想从服务器(objIn)获取对象并将其传递给 UI 线程,这样我就可以在那里进行一些 UI 更新。通过搜索一下,我认为我必须使用处理程序,但不能真正围绕实现。
有人能给我一个简单的例子,说明如何在我的情况下实现处理程序,并在主活动中进行调用吗?或者指点我一个简单的教程让我开始,因为我试图在 Android 开发者网站上关注那个,但它太复杂了。

4

0 回答 0