問題タブ [channels]

短いバージョン: go チャネルを再作成したりループしたりせずに空にする方法はありますか?

理由: データの送受信に 2 つのチャネルを使用しており、再接続が必要であることを通知するための追加のチャネルがあります。

トランスポートがリセット/再接続されたら、余分なチャネルを「空」にして、再接続を引き起こす他のリセット要求が残っていないことを確認します。

GOLANG-BOOKを読んでからgolangをいじり始めました。単純な TCP チャットを構築しようとしています。ユーザー構造体を作成しました。ユーザー配列からすべての user.inbound チャネルをリッスンしたいと思います。

ここでの問題は、user.inbound を待っているため、関数 writeUser() にあることを知っています。ユーザーの配列でこの種のチャネリングを適切に行う方法がわかりません。

これは、コンパイラから受け取ったエラーです。

• 22行目は関数 writeUser() です

そして、これは私のコードです:

プログラムでエラーが発生しました:

"org.jboss.remoting3.ProtocolException: 開いているチャネルが多すぎます"

このエラーを修正するための解決策をインターネットで検索しました。残念ながら、他の人からの提案はうまくいきません。

以下は、jndi リモートと使用したプロパティを呼び出す方法に関するコードです。

何らかの理由により、メソッドのすべての内容を表示できません。

「createUser」は、新しいユーザーを作成する必要があるたびに呼び出されます。百回、千回と呼ばれる。

メソッドの実行が終了するたびに、常に接続を閉じました。

このメソッドを 100 回呼び出したとします。一部のユーザーは正常に作成されますが、一部のユーザーは失敗します。

以下のエラーが表示されます。

エラーが発生すると、jboss を再起動する必要がありました。

私が直面している問題を解決してくれる人がいれば、感謝します。

ありがとう

パブリッシャーとして機能するチャンネルがあります。

の性質上、sub/pubこれを行うと：

メッセージはパブリケーションによって消費されますが、サブスクライバーが存在しないため、ドロップされます。

:fooトピックをサブスクライブしようとすると:

何も印刷されていません。しかし、パブリッシャーにさらにアイテムを入れると:

たとえば、サブスクライバーがまだサブスクライブしていなくてもn、パブリッシャーによって作成された最後のアイテムを失わないようにする方法はありますか?

実際に送信を試行せずに go チャネル送信の失敗をテストする方法はありますか? 標準のノンブロッキング送信は次のようになります。

問題は、チャネルをテストするために「msg」を送信する準備ができている必要があることです。

「msg」を送信する準備ができていなくても、送信が失敗するかどうかをテストしたいと思います。

http://www.golang-book.com/10/index.htm#section2のピンポンの例を考えてみましょう。

著者は次のように書いています。

「プログラムは ping と pong を交互に出力します。」

ただし、これを実現するには、送信者がチャネルに送信できる順序を Go が決定する必要があります。そうしないと、ping が pong の前に送信されるという保証はありません (つまり、2 つの ping を取得したり、2 つの pong を続けて取得したりすることはできません)。これはどのように作動しますか？