在服务器 - 客户 - 客户结构中将消息发送给特定客户端的正确方法是什么？

Question

我正在构建此程序，其中服务器向不同的客户端发送不同的订单。该程序的一部分将订单发送到服务器，服务器处理消息端的服务器，然后将其发送给应该执行的特定客户端。

这是发送消息的代码：

@Override
public void run() {
    boolean active = true;
    String oldMsgToDron = "";
    String to_print = "";
    BufferedWriter bw = new BufferedWriter(osw);
    while(active) {
        try {
            //msgToDron is declared in DronController as: public static volatile String msgToDron;
            to_print = DronController.msgToDron;

            if(to_print.equals(oldMsgToDron) == false) {
                
                System.out.println("Message we are sending to the dron: " + to_print);
                
                if(to_print.length()>45 && to_print.startsWith("!whisper") && dronId.equals(to_print.substring(9, 45))) {
                    bw.write("Server whispers:" + to_print.replace("!whisper " + dronId, ""));
                    bw.newLine();
                    bw.flush();
                    System.out.println("Message we sent to the dron: " + to_print);
                }
                
                else if (to_print.startsWith("!whisper") == false){
                    bw.write(to_print);
                    bw.newLine();
                    bw.flush();
                    System.out.println("A message for all drones has been sent.");
                }
                try{Thread.sleep(5);}catch(InterruptedException ex){ex.printStackTrace();}
                oldMsgToDron = "";
                to_print = "";
                DronController.msgToDronEsclavo = "";
            }

        }catch(IOException e) {
            try {
                active = false;
                if(bw != null) 
                    bw.close();
            }catch(IOException f) {e.printStackTrace();f.printStackTrace();break;}
        }           
    }
}

我的问题是在线程内处理该消息，该线程控制了与客户端的连接，并且在循环结束时，消息将更改为空字符串。因此，我可以连续两次发送相同的订单，并且服务器不会不断向客户端发送相同的消息。

问题是，如果我有3个或多个连接，它会开始给我带来问题，因为每当一个线程到达末端时，它们都会转动变量droncontroller.msgtodronesclavo 和oldmsgtodron要在其他线程有时间检查其分配的客户端是否为消息之前进行空字符串。

我如何避免在其他线程完成之前更改变量？这种结构是否有任何设计模式？这种类型的程序有什么好的做法？

另外，我考虑过让客户检查发送的消息是否适合他们，但我发现此解决方案不安全。

Answer 1

通常是客户通过网络连接到服务器的客户 - 请求数据或发送数据。服务器没有可靠的方法来知道何时何时连接客户或触发连接本身。

如果要将数据从服务器发送到客户端，则曾经是客户端将对数据进行轮询的模式，或者总是有一个请求等待服务器的下一个数据包。您可能需要阅读有关 ajax 和 websocket

另一种模式是安装 webhook ，它从本质上为服务器提供了可以达到客户端的URL。本质上，这将服务器交换为充当客户端和客户端，以充当此数据传输的服务器。

好吧，以上是与您的问题标题有关的。现在查看内容，您正在问如何防止线程相互影响。

了解Java关于线程同步的概念。这是不错的教程。