如何将多个客户端连接到 Android 中的服务器？

Question

我想创建一个 聊天室，其中 3 个（或更多设备）通过热点上的 Tcp 协议连接到服务器，并且服务器和客户端无法相互交谈这是我的代码当应用程序启动时，它会尝试连接到服务器（如果存在），如果它找不到服务器，那么它运行服务器套接字等待客户端但 仅一个客户端可以连接到服务器并发送和接收消息我知道我必须使用多线程但我无法处理这个请帮助我:(

 package com.app.wifi_chat;
    import java.io.BufferedReader;
    import java.io.DataOutputStream;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.net.InetSocketAddress;
    import java.net.ServerSocket;
    import java.net.Socket;
    import com.uncocoder.app.wifi_chat.R;
    import android.app.Activity;
    import android.os.Bundle;
    import android.os.Handler;
    import android.view.KeyEvent;
    import android.view.View;
    import android.view.View.OnClickListener;
    import android.widget.Button;
    import android.widget.EditText;
    import android.widget.TextView;


    public class WifiChatActivity extends Activity {

    private Handler          handler = new Handler();
    private TextView         text;
    private EditText         input;
    private Button           btnSend;
    private Socket           socket;
    private DataOutputStream outputStream;
    private BufferedReader   inputStream;

//try to connect to server if find it return true 
    private boolean searchNetwork() {
        log("Connecting...");

        String range = "192.168.1.";
        for (int i = 1; i <= 255; i++) {
            String ip = range + i;
            try {
                //log("Try IP: " + ip);
                socket = new Socket();
                socket.connect(new InetSocketAddress(ip, 9000), 10);

                log("Connected!");
                return true;
            }
            catch (Exception e) {}
        }

        return false;
    }

//run server and wait for new client
    private void runChatServer() {
        try {
            log("Waiting for client...");

            ServerSocket serverSocket = new ServerSocket(9000);
            socket = serverSocket.accept();

            log("A new client Connected!");
        }
        catch (IOException e) {}
    }


    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);

        text = (TextView) findViewById(R.id.text);
        input = (EditText) findViewById(R.id.input);
        btnSend = (Button) findViewById(R.id.btnSend);

        //server
        Thread thread = new Thread(new Runnable() {

            @Override
            public void run() {
//first time check for connect to server if not to find it then run server and wait for client
                if ( !searchNetwork()) {
                    runChatServer();
                }

                try {
                    outputStream = new DataOutputStream(socket.getOutputStream());
                    inputStream = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                }
                catch (IOException e1) {
                    log("Error: Connection is not stable, exit");
                    shutdown();
                }
//listen to client for get messeage
                while (true) {
                    try {
                        String message = inputStream.readLine();
                        if (message != null) {
                            log(message);
                        }
                    }
                    catch (IOException e) {}
                }
            }
        });
//send message to client or server
        btnSend.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                if (outputStream == null) {
                    return;
                }

                try {
                    String message = input.getText().toString() + "\n";
                    outputStream.write(message.getBytes());
                }
                catch (IOException e) {
                    e.printStackTrace();
                }
            }
        });

        thread.start();
    }

//log  messeage form client or server
    private void log(final String message) {
        long timestamp = System.currentTimeMillis();
        final long time = timestamp % 1000000;

        handler.post(new Runnable() {

            @Override
            public void run() {
                text.setText(text.getText() + "\n @" + time + ": " + message);
            }
        });
    }

//when app is kill close socket 
    @Override
    public boolean onKeyDown(int keyCode, KeyEvent event) {
        if (keyCode == KeyEvent.KEYCODE_BACK) {
            shutdown();
            return true;
        }

        return super.onKeyDown(keyCode, event);
    }


    private void shutdown() {
        try {
            if (socket != null) {
                socket.close();
            }
        }
        catch (IOException e) {
            e.printStackTrace();
        }
        System.exit(0);
    }
    }

Answer 1

你的代码一团糟。

通常你需要制作这样的东西

class ClientClass implements Runnable //用于管理客户端 { 套接字插座;

public ClientClass(Socket s)
{
    socket = s;
}

void run()
{
    //Get InputStreams
    //Manage client
}

}

ServerClass

while(true)
{
    new Thread(new ClientClass(server.accept()));//Maybe you want to store it for future comunication
}

希望对您有所帮助。

如何将多个客户端连接到 Android 中的服务器？

how connect multiple client to a server in Android?

java

multithreading

android

tcp

chat