consumer

0熱

1答えて

以下の設定があります。サーバーは、クライアント上で実行されるプロデューサからの受信ActiveMQメッセージを待ち受けます。私は顧客から消費者を作ることを避けたい。さもなければ、どんなクライアントもバス上のすべてのメッセージを盗聴でき、これは重大なセキュリティ上の欠陥です。プロデューサーのみを作成するようにクライアントを制限する方法はありますか？

0熱

1答えて

どのようにkafkaトピックからすべてのメッセージを取得し、それらをJavaを使用して数えますか？

このコードは時々私に最初からすべてのメッセージを与え、別のメッセージを待っていると、時にはそれだけで話題からのすべてのメッセージは、それらを送信されますされて私は何をしなければならない別のメッセージ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Propertie

0熱

1答えて

RabbitMQプロデューサーからのメッセージを受信していないコンシューマー

こんにちは、私はrabbitMQでメッセージを送信しようとしています。私は直接交換を宣言し、それをプロデューサー側の待ち行列にルーティングしていますが、私は消費者でメッセージを受け取ることができません。次のように package com.rabbit.consumer; import java.io.IOException; import java.util.concurrent.Timeo

0熱

1答えて

Kafkaサーバーにはメッセージが含まれていますが、コンシューマーは受信できません（プロデューサはcompression.type = snappyを使用しています）

私はKafkaの初心者です。カフカ0.9.0を使用すると、私のkafkaプロデューサーのcompression.typeプロパティを設定してコーデックを設定できます。は、私は、私のプロデューサーでsnappy圧縮を使用する一部のカフカ - 消費者を使用してカフカからのメッセージを消費したときに、私はに何かを行う必要がありますてきぱきからデータをデコードするか、いくつかの内蔵カフカの消費者の特徴で

6熱

2答えて

Java 8のjava.util.function.Consumer <>のC＃に相当するものは何ですか？

C＃にはこのインタフェースと同等の機能がありますか？例： Consumer<Byte> consumer = new Consumer<>(); consumer.accept(data[11]); 私はのFunc <周りを検索しました >とアクション<>が、私はわかりません.... Consumer.acceptの元のJavaコード（）インタフェースはかなりありますシンプル..しかし、私

1熱

1答えて

WcfRequestProcessorClientをどのように消費するのですか？

WcfRequestProcessorClientクラスを使用してWCFサービスを使用する必要があります。どのようにC＃を使用する適切な方法はありますか？ async/awaitで可能なのでしょうか？

-1熱

1答えて

リーダライタ：セグメンテーションフォールトC++

ウェブカメラをシミュレートする小さなプログラムがあります。したがって、フレーム（私のプログラムではデータの値）を2つのファイルと画面に保存する必要があります。しかし、私は私のコードを実行するとき、私はセグメンテーションフォールトを取得します。 #include <iostream> #include <fstream> #include <pthread.h> #include <stdli

1熱

2答えて

C：プロデューサー/コンシューマー

学校での私の仕事の1つは、このコードを修正することです。プロデューサとコンシューマスレッドは、ローカル変数を交互にインクリメントして出力する必要がありますが、どのように修正するかわかりません。プロデューサとコンシューマのスレッドが無期限に実行できる可能性がありますが、実行可能ファイルを開始すると、任意に停止します。誰かがこの行動を私に説明できるのは素晴らしいことです。ここでコードは次のとおり

-1熱

1答えて

ファイルを一度正確に処理する方法

Javaアプリケーションがディレクトリからデータを読み取り、共通の共有リソースキューに入れると、コンシューマはイベントを消費してイベントを検証し、データベースに保存します。ディレクトリ内のファイルを処理したいアプリケーションが再起動しても一度だけファイルを処理してはならず、停止していた場所からファイルを開始する必要があります。