nsq

0熱

1答えて

私はスレッドでioloopを実行し、メッセージをnsqdに書き込むだけです。試してみてください： #!/usr/bin/env python2 # coding=utf-8 import tornado import time from nsq.writer import Writer w = Writer(["bj1:4150", "bj2:4150"], reconnect_in

0熱

1答えて

NSQ PetSetを作成しようとしてい、ポッドは、コンテナがここに

完全なYAMLファイル（重要なビットの多くは、以下のdescribeによって覆われているので、それはかなり長いですので、質問に埋め込まれていない）が起動直後に終了しておく： https://gist.github.com/sporkmonger/46a820f9a1ed8a73d89a319dffb24608を私はここで作成した公共コンテナイメージを使用する：sporkmonger/nsq-k8

0熱

1答えて

NsqjsはPynsqに比べて本当に遅いですか？

私はjavascriptの var nsq = require('nsqjs'); var reader = new nsq.Reader('output', 'out', { lookupdHTTPAddresses: '172.32.10.224:4161' }); reader.connect(); reader.on('message', function (ms

0熱

1答えて

なぜnsqlookupdパッケージがContextを使用していますか？

nsqソースコードのnsqlookupdの部分を読むと、作者がNSQLookupd構造体をラップするためにContext構造体を使用し、Context.Iには他のfuncsを使用していないことがわかりました。この方法で取得しますか？以下はソースコードです。ありがとうございました！ func (l *NSQLookupd) Main() { ctx := &Context{l} tcpList

1熱

1答えて

メッセージングアーキテクチャを使用してメッセージを送信者に送り返す方法は？

私は、メッセージングアーキテクチャを備えたマイクロサービス間の通信を解決しています。私は伝統的なアプリケーションを持っており、User,PostVideoモジュールがあるとします。投稿とビデオを作成することはできますが、その前にユーザー名をユーザーIDに変換する必要があります。私はmicroserviceにモジュールを分割したら、私はそれらを一緒に連鎖することはできません、我々は代わりに直接

4熱

1答えて

データベースをマイクロサービス（および新しいもの）と同期させるにはどうすればよいですか？

私はマイクロサービスアーキテクチャを持つウェブサイトを開発しており、各サービスはデータベースを所有しています。データベースは、マイクロサービスが必要とするデータを格納する。 Post、Videoサービスは、ユーザー情報が必要なので、サービスの両方がNEW_USER_EVENTに加入。 NEW_USER_EVENTは、新しいユーザーが登録されたときにトリガーされます。サービスがNEW_USER_E

0熱

2答えて

Kubernetesエンドポイントを取得

私はnsqlookupdサービスを提供する一連のポッドを持っています。これで、接続するnsqlookupdサーバーのリストを（サービスは毎回異なる点を指していますが）同時に作成するために、各nsqdコンテナが必要です。似たような私は kubectl describe service nsqlookupd ... Endpoints: .... を得るが、私は私の展開定義内の変数でそれをし