在服务套接字连接的两个线程之间共享公共数据。
我在上面看到了很多类似的问题，但他们中几乎没有一个在图片上有Socket。所以请花点时间阅读这个问题。
我有服务器应用程序(使用ServerSocket)侦听请求，当客户端试图连接时，将创建新线程来服务客户机(而服务器将恢复侦听新请求的模式)。现在，我需要根据其他客户端发送到服务器的内容来响应一个客户端。
示例：
- ServerSocket监听传入连接。
- 客户端A连接，创建新线程以服务A。
- 客户端B连接，创建新线程以服务B。
- A向服务器发送消息"Hello from A“。
- 将此消息作为客户端B的响应发送。
我对“线间交流”这件事很陌生。显然，上面提到的情况听起来非常简单，但我描述这是为了得到提示，因为我将在保持服务器为中间的客户端之间交换大量数据。
另外，如果我希望将共享对象限制在特定客户端上，比如10呢？这样，当第11个客户端连接到服务器时，我创建了一个新的共享对象，用于在11、12、13之间交换数据……多达20名客户。以此类推，每一组10个客户。
我尝试了什么：(我猜是愚蠢的)
- 我有一个
public类，该对象应该作为public static共享，这样我就可以将它作为全局类使用，而无需实例化它，比如MyGlobalClass.SharedMsg。 - 这不起作用，我无法将一个线程中接收到的数据发送到另一个线程。
我知道存在一个明显的锁定问题，因为如果一个线程正在写入一个对象，另一个线程在完成第一个线程的写入之前不能访问它。
那么，什么才是解决这个问题的理想方法呢？
更新
由于我创建线程以服务传入连接请求的方式，我无法理解如何在线程之间共享同一个对象，因为上面提到的使用全局对象是行不通的。
下面是我如何侦听传入的连接并动态创建服务线程。
// Method of server class
public void startServer()
{
if (!isRunning)
{
try
{
isRunning = true;
while (isRunning)
{
try
{
new ClientHandler(mysocketserver.accept()).start();
}
catch (SocketTimeoutException ex)
{
//nothing to perform here, go back again to listening.
}
catch (SocketException ex)
{
//Not to handle, since I'll stop the server using SocketServer's close() method, and its going to throw SocketException anyway.
}
}
}
catch (Exception ex)
{
ex.printStackTrace();
}
}
else
System.out.println("Server Already Started!");
}还有ClientHandler类。
public class ClientHandler extends Thread
{
private Socket client = null;
private ObjectInputStream in = null;
private ObjectOutputStream out = null;
public ClientHandler(Socket client)
{
super("ClientHandler");
this.client = client;
}
//This run() is common for every Client that connects, and that's where the problem is.
public void run()
{
try
{
in = new ObjectInputStream(client.getInputStream());
out = new ObjectOutputStream(client.getOutputStream());
//Message received from this thread.
String msg = in.readObject().toString();
System.out.println("Client @ "+ client.getInetAddress().getHostAddress() +" Says : "+msg);
//Response to this client.
out.writeObject("Message Received");
out.close();
in.close();
client.close();
}
catch (Exception ex)
{
ex.printStackTrace();
}
}
}我认为，我创建动态线程以服务每个连接、共享相同数据源的客户端的方式是不可能使用全局对象的，因为上面的run()主体对于每个连接的客户端都是完全相同的，因此，同样的方法既是使用者也是生产者。我应该做哪些修正，以便为每个连接创建动态线程，并且仍然共享相同的对象。
回答 1
Stack Overflow用户
发布于 2012-06-08 06:17:56
您可能需要一个队列，用于每个客户端之间的通信。每个队列将是数据从一个客户端推送到另一个客户端的“管道”。
您可以这样使用它(伪代码)：
Thread 1:
Receive request from Client A, with message for Client B
Put message on back of concurrent Queue A2B
Respond to Client A.
Thread 2:
Receive request from Client B.
Pop message from front of Queue A2B
Respond to Client B with message.您可能也希望它是通用的，因此您有一个AllToB队列，许多客户端(因此还有许多线程)都可以写入该队列。
注意类别：ConcurrentLinkedQueue，ArrayBlockingQueue。
如果您想限制消息的数量，那么ArrayBlockingQueue及其容量构造函数允许您这样做。如果不需要阻塞功能，则可以使用offer和poll方法，而不是put和take方法。
我不担心共享队列，这会使问题变得更加复杂。只有当您知道您需要解决内存使用问题时，才可以这样做。
编辑:基于您的更新的：
如果需要在所有动态创建的实例之间共享单个实例，则可以：
- 创建一个静态实例。
- 将其传递到构造函数中。
1例：
public class ClientHandler extends Thread
{
public static final Map<ClientHandler, BlockingQueue<String>> messageQueues
= new ConcurrentHashMap<>();
<snip>
public ClientHandler(Socket client)
{
super("ClientHandler");
this.client = client;
// Note: Bad practice to reference 'this' in a constructor.
// This can throw an error based on what the put method does.
// As such, if you are to do this, put it at the end of the method.
messageQueues.put(this, new ArrayBlockingQueue<>());
}
// You can now access this in the run() method like so:
// Get messages for the current client.
// messageQueues.get(this).poll();
// Send messages to the thread for another client.
// messageQueues.get(someClient).offer(message);几个注意事项：
- messageQueues对象实际上应该包含某种类型的客户端标识符，而不是一个短暂的对象引用。
- 更易测试的设计将把messageQueues对象传递到构造函数中，以允许模拟。
- 我可能会建议对映射使用包装类，因此您可以只使用2个参数调用having，而不必担心映射语义。
https://stackoverflow.com/questions/10943841
复制相似问题
腾讯云开发者
