publish-subscribe

0熱

1答えて

Java Event driven Pub/Sub systemサブスクライバがプロデューサより遅い

サブスクライバがプロデューサより遅いシステムを設計する必要があります。私は（予算制約のために）MQソリューションを使用することはできません。プロデューサがデータをキューに入れ、サブスクライバが特定の間隔でポーリングするインメモリキューを使用できますか？ Java 7を使用して実装する方法。 Google Guava EventBusは同じものを使用できますか？ はいの場合は、ソリューションの実装方

java guava publish-subscribe 2017-11-29

---

0熱

1答えて

クラウド上のPub Subを使用したソケットクラスタ

WebAppのフロントエンドにトランスポートレイヤを作成しています。ユーザーはモバイルアプリ、ブラウザの両方で接続することができます。トランスポート層は、チャットアプリケーション、マルチページウェブアプリケーション、通知、および電子メールサーバを含む複数のアプリケーションに対応しています。規模は約4000人の同時ユーザーです。いくつかのシナリオ異なるサービスが相互にやり取りする必要があるかもしれま

websocket redis netty publish-subscribe socketcluster 2017-12-04

---

0熱

1答えて

Lagomパブリッシュメッセージ（カフカ付き）

公開方法は1つだけですhere。 別の方法がありますか？ この例では、persistentEntityRegistryを使用せずに動的トピックIDとカスタムイベントを使用してパブリケーションを作成する必要がありますか？ eventIdでイベントを公開するにはどうすればよいですか？ @Override default Descriptor descriptor() { retur

java apache-kafka publish-subscribe lagom 2017-12-04

---

3熱

1答えて

Akka Distributed Pub/Subバックプレッシャー

私はAkka Distributed Pub/Subを使用しており、出版社とサブスクライバは1つです。私の出版社は加入者よりもずっと高速です。ある時点後に出版社を遅らせる方法はありますか？ 出版社コード： public class Publisher extends AbstractActor { private ActorRef mediator; static publi

java akka publish-subscribe akka-stream akka-cluster 2017-12-11

---

0熱

1答えて

データベースが実装で使用される場合、Observerパターンとpub-subは同じですか？

私は観察者のパターンを理解しようとしていて、ある特定の点で立ち往生しています。私の理解では、観察者がイベントの変更を通知するために加入すると、サブスクリプションはどこかに格納され、イベントが変更されるとサブスクライバに通知されます。 実際のシナリオでは、永続性の理由からデータベースまたはファイルに値を格納し、DBから取得してリストをループすることでイベントが発生したときにその値を通知する必要があり

c# design-patterns design publish-subscribe observer-pattern 2017-12-12

---

0熱

1答えて

RTIのDDS実装におけるグローバル・データ・スペース

誰でもDDSのグローバル・データ・スペースについて簡単に説明できますか？ 仮想メモリのようなものですか？グローバルデータスペースはいつ必要ですか？ 私は、UDPv4のユニキャストでは、すべてのdataWriter/dataReaderペアに対して、通信がdataWriterとdataReaderの間で行われる1つのポートが割り当てられていることを知っています。次に、グローバルデータスペースの概念は

udp publish-subscribe dds data-distribution-service opendds 2017-12-12

---

0熱

1答えて

他のユーザにメッセージを渡すには？

それはパブリッシャーとサブスクライバーを持っている、とサブスクライバがパブリッシャに加入すると、加入者はまた、次のメッセージを実装として、私は、Java 9 の反応ストリームAPIを学んでいます： public class TestSubscriber<T> implements Subscriber<T> { @Override public void onComplete

reactive-programming publish-subscribe java-9 reactive reactive-streams 2017-12-22

---

1熱

1答えて

購読者は発行者として行動できますか？

リアクティブストリームに関しては、パブリッシャが存在し、多数のサブスクライバを持つことができます。 ただし、購読者がPublisherからメッセージを受け取ったとします。このサブスクライバ（Subs1）はメッセージを変更/変更し、変更されたメッセージを消費する他のサブスクライバ（Subs2など）に渡します。 このSubs1サブスクライバは、新しいSubs2サブスクライバにメッセージを渡すことができ

reactive-programming publish-subscribe java-9 reactive reactive-streams 2017-12-22

---

1熱

1答えて

2つのFluxをzipWithを組み合わせて使用​​するとエラーが発生する

反応性のあるストリームを学習し、次のように2つのFluxを組み合わせようとしています。 List<Integer> elems = new ArrayList<>(); Flux.just(10,20,30,40) .log() .map(x -> x * 2) .zipWith(Flux.range(0, Integer.MAX_VALUE

publish-subscribe spring-webflux reactive-streams 2017-12-28

---

0熱

1答えて

は、送信者、他のユーザーにメッセージを送信する必要はありませんWebSocketを

の上に私はWebSocketを超えるパブリッシュ/サブスクライブのメカニズムを構築しています。私はWebSocketを動作させていますが、userA、userC、userD（これらはpub/subに登録されている他のユーザ）にメッセージを送信するにはどうすればいいですか？ 私はwebsocketsharpを使用していると私は開いているセッションのリストを持っているので、私はのSendToを使用しよ

c# websocket publish-subscribe 2017-12-29

---