akka-zeromq

0熱度

1回答

我有以下控制流。在for循環中，我創建了一個字符串數組。我將數組的每一行（一個字符串）發送給發佈者函數。然後發佈者函數應該發送字符串。如果發佈者正在以無限循環發佈，我的訂閱者只收到郵件，我遇到了問題。爲什麼我不能連續調用發佈者函數並讓它發送數據？爲什麼它只能在無限循環中工作？這裏是我的出版商功能： int zedMQserver(std::string output) {

3熱度

1回答

哪種協議是Apache的飛艇用於連接到Apache的火花？（IPython的/ ZeroMQ）？

我wondring阿帕奇齊柏林用來連接到Apache星火哪些協議？是不是也ZeroMQ IPython的協議？非常感謝！問候羅密歐

0熱度

2回答

Zeromq如何使一個C++服務器程序，它允許它不等待客戶端請求

我想Zeromq世界您好服務器和客戶端的例子。下面是示例代碼 // // Hello World client in C++ // Connects REQ socket to tcp://localhost:5555 // Sends "Hello" to server, expects "World" back // #include <zmq.hpp> #include <str

0熱度

1回答

阿卡 - zeromq插座/演員將不會收到消息

Questuion 我想實現一個簡單的演員將從zeromq使用阿卡 - zeromq接收消息。 import akka.actor._ import akka.zeromq._ class PullActor extends Actor { def receive = { case x => println("M: " + x.toString) } }

1熱度

1回答

Akka MapReduce配置與ZeroMQ？

我是Akka的新手，並且希望構建一個允許多個分佈式模式的小框架，例如MapReduce，Publish-Subscribe等。我已經看到使用ZeroMQ作爲Akka的網絡提供者是可能的，我更喜歡它。但是，當我看到一些MapReduce examples時，它們都依賴netty.io框架進行網絡連接。爲了有一個單一的網絡提供商ZeroMQ ...有沒有一個簡單的方法來取代netty io網絡與Ze

2熱度

2回答

Heroku上的ZeroMQ

Heroku爲什麼不存在？我想使用Akka和分佈式隊列系統讓演員在不同的dynos上進行通信。 RabbitMQ似乎不是使用Akka的最佳選擇，因爲需要很多技巧才能與演員無縫協作，而不必關心底層隊列。儘管如此，最好的選擇似乎是Durable Mailboxes，但與RabbitMQ：akka-amqp-mailbox。但我仍然必須先設置它。你認爲哪些其他選項可以在Heroku上使用Akka提

1熱度

1回答

Akka ZeroMQ pub/sub創建訂單

訂單對於創建發佈者和訂閱者是否重要？如果我有應用程序A，充當發佈者和多個客戶端應用程序X1-Xn（作爲應用程序A的訂戶），我可以首先啓動子應用程序，將它們註冊爲訂戶，然後再啓動應用程序A？我是否需要啓動應用程序A？

0熱度

1回答

阿卡路由器具有多個行動者無法接收消息正確

在這裏，我創建的路由器與SmallestMailboxRouter ActorRef actorRouter = this?.getContext()?.actorOf(new Props(RuleStandardActor.class).withRouter(new SmallestMailboxRouter(38)),"standardActorRouter") 現在，在for循環我創建3