使用Mqtt訂閱器與主類進行通信

Question

我有一個主類在另一個線程（基本上是一個偵聽郵件到達的服務）中轉發mqtt訂閱者。當用戶收到該消息時，我需要它轉發到我的主類，以便它可以對該消息進行計算。

在訂戶中，我有一個messageArrived函數。我並不確定如何將這些信息傳達給我的主要班級。我想可能是某種類型的網絡，比如從訂閱者發送套接字到監聽的主類。但想考慮其他建議。所有這些都在同一臺機器上完成。

片段從得到在從主類另一個線程起轉訂戶：

@Override 
public void messageArrived(String topic, MqttMessage message) throws MqttException{ 
//send message to main class somehow... 
} 

需要消息而從上面的代碼主類：

new Thread(optSubscriber).start(); //spin up subscriber service to listen for messages aka messageArrived 

//somehow grab that message from messageArrived and place into next function 
computeMessageFromSubscriber(message); 

Answer 1

推送消息對象集合（例如向量），然後從處理線程輪詢該集合。

此外，而不是做一個預定的單個線程的工作，爲什麼不看看java.util中的線程池的模型，它在擴展

https://docs.oracle.com/javase/tutorial/essential/concurrency/pools.html