java - 一对多TCP通信

Question

我正在尝试将一个基本的 Java 概念验证放在一起，让一台服务器(很可能只是一台 Windows 或 Linux 笔记本电脑)可以向同一台上的多个连接 WIFI 的安卓设备发送消息子网(最初为 20-30，但将来可能会增加很多 - 2 或 300？ - 不确定，但我需要考虑到这种可能性)。该应用程序将向所有设备发送一条消息(最初是相同的消息 - 但我可能会在轨道的某个地方允许特殊情况)。然后每个设备都可以回复，我想检查哪些设备回复并存储回复。

我尝试了一些使用 UDP 的测试代码(在 nakov.com 上的教程的帮助下)，但它非常不可靠，并且手机在尝试接收数据包时经常被锁定 - 尽管它有时工作得很好。我的 android 设备的客户端代码如下所示以供引用(注意，此代码只是发送消息请求，然后接收并显示它 - 我没有按照我想要的方式编写它，因为它没有'无论如何都不够可靠)。

因此，我认为我可能需要使用 TCP 来提高可靠性(尽管我愿意接受建议)。 2-300 个单独的 TCP 并发连接可以吗？而且很可能所有回复都会立即(或超过 10-15 秒)进入服务器，这会以无法处理的方式淹没它吗？是否仅适用于 20-30 台设备？

我知道这是一个悬而未决的问题，但我希望比我更了解 TCP 的人可以阐明一些问题并给我一些指导。

干杯

史蒂夫

UDP 客户端应用程序:

package nz.co.et.quoteclient;

import java.io.IOException;
import java.net.DatagramSocket;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;

import android.app.Activity;
import android.content.Context;
import android.net.wifi.WifiManager;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.TextView;
import android.widget.Toast;

public class QuoteClient extends Activity {
    /** Called when the activity is first created. */
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);

        Button button = (Button) findViewById(R.id.Button01);

        button.setOnClickListener(new OnClickListener() {
            public void onClick(View v) {
                WifiManager wifiManager = (WifiManager) getSystemService(Context.WIFI_SERVICE);
                if (wifiManager.isWifiEnabled()) {

                    TextView errorText = (TextView) findViewById(R.id.TextView01);
                    int serverPort = 4445;
                    InetAddress address = null;
                    try {
                        address = InetAddress.getByName("192.168.1.4");
                    } catch (UnknownHostException e) {
                        errorText.setText("Failed at setting server IP Address");
                        e.printStackTrace();
                    }

                    byte[] buf = new byte[256];
                    DatagramPacket packet = new DatagramPacket(buf, buf.length, address, serverPort);

                    DatagramSocket socket = null;
                    try {
                        socket = new DatagramSocket();
                    } catch (SocketException e) {
                        errorText.setText("Failed at creating socket");
                        e.printStackTrace();
                    }
                    try {
                        socket.send(packet);
                    } catch (IOException e) {
                        errorText.setText("Failed at sending request packet");
                        e.printStackTrace();
                    }

                    // get response
                    packet = new DatagramPacket(buf, buf.length);
                    try {
                        socket.receive(packet);
                    } catch (IOException e) {
                        errorText.setText("Failed at receiving quote packet from server");
                        e.printStackTrace();
                    }

                    // display response
                    String message = new String(packet.getData());
                    String data = "";
                    for (int i = 0; i < message.length(); i++) {
                        int tmp = (int) message.charAt(i);
                        data = (tmp <= 0 || tmp >= 256) ? data += "" : data + message.charAt(i);
                    }
                    Toast.makeText(getApplicationContext(), data, Toast.LENGTH_LONG).show();
                    // errorText.setText(data);
                }

                else {
                    Toast.makeText(getApplicationContext(), "WIFI not enabled", Toast.LENGTH_LONG).show();
                }
            }
        });
    }
}

Answer 1

TCP 肯定会比 UDP 更可靠，因为 UDP 不保证数据包交付(这可能是您的应用程序在接收时挂起的原因)。

2-300 个连接应该是可管理的，但这将取决于您的硬件功能和正在处理/来回发送的数据量等因素。

您还必须围绕以下事项做出一些决定:

• 您使用什么语言(java？)编写您的服务器？

• 您是维护从客户端到服务器的持久连接，还是每次都重新创建它？

• 谁负责建立连接(客户端还是服务器)？

• 服务器将如何识别哪个设备收到了消息，它是否绑定(bind)到 IP 地址，或者是否正在进行某种握手以识别客户端。

• 如果客户端建立连接，您是否需要发送之前错过的所有信息？

• 信息是否需要同时到达所有客户，还是可以错开？

• 如果您的客户端应用程序失去连接、重试等，它会如何表现？

list 还在继续......