Студия Android: сервер и клиент Socket.io - PullRequest
Новая
       23

Студия Android: сервер и клиент Socket.io

0 голосов
/ 22 сентября 2018

Я пытаюсь запустить простой клиент-сервер socket.io в Android Studio, в основном я использую socket.io для клиента и в потоке сервера, который я использую https://github.com/mrniko/netty-socketio. Но клиент не можетподключиться (но мне удалось подключиться к другому серверу, не реализованному на Android кем-то еще).Вот мой код для клиента и сервера: 

@Override
public void onCreate(Bundle savedInstanceState)
{
    super.onCreate(savedInstanceState);
    setContentView(R.layout.test_class_activity);
    findViewById(R.id.connect_socket).setOnClickListener(new View.OnClickListener() {

        @Override
        public void onClick(View v) {
            Thread clientThread = new Thread(new Runnable() {
                @Override
                public void run() {
                    if (mSocket==null || !mSocket.connected()) {
                        try {
                            mSocket = IO.socket("http://127.0.0.1:" + PORT);
                        } catch (URISyntaxException e) {
                            System.out.print(e.getMessage());
                        }

                        if(mSocket!=null) {
                            mSocket.on(Socket.EVENT_CONNECT, new Emitter.Listener() {

                                @Override
                                public void call(Object... args) {
                                    Log.d("ActivityName: ", "socket connected");
                                    //socket.disconnect();
                                }
                            }).on(Socket.EVENT_MESSAGE, new Emitter.Listener() {

                                @Override
                                public void call(final Object... args) {
                                    Log.d("ActivityName: ", "msg received: " + args[0].toString());
                                    runOnUiThread(new Runnable() {
                                        @Override
                                        public void run() {
                                            ((TextView)findViewById(R.id.response_server)).setText(args[0].toString());
                                        }
                                    });
                                    mSocket.emit(Socket.EVENT_MESSAGE, "salut Sam c est Adrien. J ai recu ton message: \"" + args[0].toString() + "\"");
                                }
                            });
                            mSocket.connect();
                        }
                    }
                }
            });
            clientThread.start();
        }
    });

    findViewById(R.id.start_server).setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            try {
                server();
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
        }
    });

private static void server() throws InterruptedException, UnsupportedEncodingException {
    if(server!=null) {
        Configuration config = new Configuration();
        config.setHostname("localhost");
        config.setPort(PORT);
        server = new SocketIOServer(config);
        server.addEventListener("toServer", String.class, new DataListener<String>() {
            @Override
            public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
                client.sendEvent("toClient", "server recieved " + data);
            }
        });
        server.addEventListener("message", String.class, new DataListener<String>() {
            @Override
            public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
                client.sendEvent("toClient", "message from server " + data);
            }
        });
        server.start();
    }
}

}

У вас есть идея, почему мой клиент не может подключиться?

...