message-queue

0熱

1答えて

stompのキュー間でデータを共有することはできますか？新しいプロジェクトがあり、私の仕事はあるキューから別のキューにデータを渡すことです。 ActiveMQとStompを持つシステムを考えてみましょう。このシステムでは、queue1で戻ってqueue2に渡すメッセージを見つけました。これは私にはあまり意味がありません。この問題に関するアドバイスをいただければ幸いです。使用事例： QUEUE1：

0熱

1答えて

mq_receiveがメッセージを長すぎると言っています

私は、単純なmsgキューの動作を習得しようとするLinuxプログラミングには新しいです。しかし、以下のメッセージは長い間、エラーメッセージが表示されます。私は同じような質問を何度も聞いていますが、コードを掲示して私のprobelmに解決策を見つけることができませんでした。 #include <stdio.h> #include <pthread.h> #include <fcntl.h>

1熱

4答えて

カフカのメッセージにタイプを追加しますか？

私たちはバックエンドの再開発でKafkaを使用し始めており、私たちが生産し消費するメッセージをどのように構造化するかについては簡単に質問しています。ユーザーに対してCRUD操作を処理するユーザーマイクロサービスがあるとします。可能性として提出された2つの構造は以下の通りです。 1）各操作ごとに1つのカフカのトピックが4つあります。メッセージ値だけ操作を実行するために必要なデータ、すなわち top

0熱

2答えて

kafkaとhttpで対話する

Elasticsearchには、httpを介して設定されたほぼ完全なAPI機能があるようです（たとえば、indices can be created via a PUT request）。現時点では、http：//www.kafka.comで、類似したトピックを作成できますか？

1熱

1答えて

複数インスタンスサービスの不要な作業を減らす

私はサードパーティのWebサービスに接続し、情報を取得してmongoコレクションに保存する小さなサービスを持っています。このサービスが興味を持っているデータはかなり静的ですが、例外的な状況（それはサッカースケジュール、btwです）の下で変更することができます。変更の通知を受けるために、サービスは3〜6時間ごとにチェックして、一致またはキャンセルされた一致があるかどうかを確認します。新しいエントリは

1熱

1答えて

RabbitMQ - キュー内のメッセージ数を制限する方法はありますか？

キューがRabbitMQで保持できるメッセージの最大数を制限する方法はありますか？たとえば、この番号が10に設定され、現在のサイズが10の場合、新しいメッセージがキュー（FIFO）にプッシュされると、最も古いメッセージが破棄されます。

2熱

1答えて

__consumer_offsetsのキリングノードは、消費者にメッセージ消費をもたらしません

複製ファクタ2を持つ3つのノード（nodes0、node1、node2）Kafkaクラスタ（broker0、broker1、broker2）と、Zookeeper（Kooka tarでパッケージ化された別のノード（ノード4）。私はzookeperを開始して残りのノードの後にブローカ0を起動しました。それは__consumer_offsetsを読んでいるブローカー0ログで見られ、それらは、ブロ

0熱

1答えて

ブローカなしでコンシューマにメッセージを渡す方法

プロデューサ独自のSynchronizedBlockingQueueを持つ異なるスレッド。各プロデューサはメッセージをそれ自身のキューに入れます。キューのいずれかのいずれかからのメッセージを取得し、プロセスを開始します消費者別のスレッド。プロデューサーとコンシューマーのコミュニケーションには、ブローカーが必要です。ボトルネックになる可能性があります。消費者がプロデューサーと開始プロセスから

0熱

1答えて

プログラムでApache ActiveMQを設定する

Apache ActiveMQを使用して大量のメッセージをキューに入れ、終わりにデキューします。私はActiveMQの機能について混乱しています。私のPCには、ActiveMQをサービスとしてインストールしていないし、どこかにサーバーのインストールがない。私はちょうど私のプロジェクトでMavenの依存関係として「ActiveMQの-すべて-5.14.5.jarを」が含まれていると私は、これまでに以

0熱

1答えて

Laravel - スキーマ - MySql - Tempテーブル "既に存在しています"

私は、WebアプリケーションにはLaravel 5.4、メッセージキュー層にはRabbitMQ、Laravelキューワーカーは使用しています。私は2つの関連する問題があります。一時表をI私のコンストラクタで、次のテーブルを作成するコードがあります。 Schema::create('tmp_products', function (Blueprint $table) { $tabl