問題タブ [stomp]

メッセージを送信する前に、コンシューマーが実行されているかどうかを確認する方法があるかどうか疑問に思っていますか？私は最新のphpSTOMPを使用していますが、メッセージを送信してキューに蓄積する前に、実行されているかどうかを検出する方法があるかどうかを確認するのに苦労しています。

ありがとう、スティーブ

私は現在、サーバーからイベントの通知を受信するためにWebSocket接続を必要とするWebアプリケーションを開発中です。

クライアントはグループに分けられ、グループ内のすべてのクライアントは同じイベント通知を受信する必要があります。

ActiveMQは、クライアントのグループごとに異なるキューを使用して、おそらくこのモデルをサポートできると思いました。また、stompを使用してイベントをActiveMQにプッシュし、クライアントにstomp-over-websocketsを使用することも比較的簡単です。

私が見ている問題は、メッセージが1つのクライアントだけで消費されるのではなく、キューに接続されているすべてのクライアントに配信される必要があるということです。

また、キューは保存しないでください。イベントの生成時にクライアントが接続されていない場合、クライアントはイベントを受信しません。

ActiveMQについてはあまり知らないので、これが可能かどうか、または独自のメッセージサーバーを作成する代わりに使用できる別の簡単なソリューションがあるかどうかはわかりません。

ありがとう

STOMP 1.0 プロトコルの説明 (http://stomp.github.com/stomp-specification-1.0.html) から (強調鉱山):

クライアントが CONNECT フレームを送信した後、サーバーは常に次のようなフレームを送信して接続を確認します。

接続されたセッション:

^@

session-id ヘッダーは、このセッションの一意の識別子です(ただし、実際にはまだ使用されていません)。

質問:

1) 接続後に返される session-id 値は、STOMP クライアントとブローカー間の接続ごとに一意であると想定します。ただし、上記の説明では「接続」と「セッション」という別の用語を使用しているため、必ずしもそうであるとは限りません。セッションIDとサーバーへの接続との関係を説明するドキュメントはありますか、誰かが私の仮定を確認できますか?

2) session-id 値の形式に関するドキュメントはありますか?

これらの質問に対する回答を Google で検索しても、有用な情報は見つかりませんでした。ActiveMQ 5.4.2 (私が使用しているブローカー) のソース コードも調べてみましたが、明確な情報は見つかりませんでした。

質問 1 はおそらく頭を悩ませていますが、私は顧客の製品に session-id 値を使用することを計画しており、STOMP がどのように動作するかを推測するよりも知りたいと思っています。

よろしくお願いします。

-ジョン

コンシューマの 1 つにエラーが発生しているように見える PHP トランザクションをデバッグしようとして頭を悩ませています。新しいメッセージを挿入する前に、プロセス リストを GREP することでコンシューマーが実行されているかどうかを検出できますが、以前に何があったのか、何が致命的なエラーの原因となったのかを知る方法はありません。

私のPHPコンシューマーはおおよそ次のとおりです。

致命的なエラーや無限ループから抜け出す何かをキャッチする方法はありますか?

ありがとう、スティーブ

Ruby から JMS メッセージを送信する方法を理解しようとしています。Ruby 側で Stomp を使用して、JMS と Ruby の間のインターフェイスとして StompConnect をセットアップしました。

telnet を使用して自分のキューと通信できますが、Ruby が StompConnect と適切に通信するのに問題がありました。

現在、私は ActiveMessaging を使用して通信を行うことを試みており、独自のポーラー スクリプトを作成しました。キューが作成され、メッセージが送信されると、次のエラー メッセージがスローされます。

=> /queue/HelloWorld へのサブスクライブ (ApplicationProcessor で処理) "[C4043]: プロパティ名に不正な文字が使用されています - -"}' body='javax.jms.JMSException: [C4043]: 不正な文字が使用されていますプロパティ名 - - 最上位の com.sun.messaging.jmq.jmsclient.MessageImpl.checkValidPropertyName(MessageImpl.java の 757 行目 最上位の com.sun.messaging.jmq.jmsclient.MessageImpl.checkAndSetProperty(MessageImpl)最上位の 821 行の .java com.sun.messaging.jmq.jmsclient.MessageImpl.setObjectProperty(MessageImpl.java の最上位の 2054 行 org.codehaus.stomp.jms.StompSession.copyStandardHeadersFromFrameToMessage(StompSession.java) org.codehaus.stomp.jms.StompSession.convertFrame(StompSession.java の最上位レベルの 234 行目 org.codehaus の最上位レベルの 257 行目)stomp.jms.StompSession.sendToJms(org.codehaus.stomp.jms.ProtocolConverter.onStompSend(ProtocolConverter.java org.codehaus.stomp.jms. ProtocolConverter.onStompFrame(ProtocolConverter.java at org.codehaus.stomp.tcp.TcpTransport.run(TcpTransport.java at line 131 at top level at java.lang.Thread.run(Thread.java at 680行目 ' >run(680 行目の Thread.java ' >run(680 行目の Thread.java ' >

現在、設定しているどのプロパティにも「-」はありません。これは Stomp ライブラリ自体の問題でしょうか? これは、最初に Ruby から StompConnect と通信しようとして遭遇した問題とほぼ同じです。

RubyからJMSと通信して、他の人はどのようにこれを回避していますか? 前もって感謝します！

チャットのようなものを書くために、軌道/ストンプサーバーと一緒にdjangoサーバーを使用しています。一部のユーザーが orbited に接続しているとします。そのうちの 1 つが軌道から切り離された場合、どうすれば他の人に通知できますか? 私は次のコードを試したことを意味します（クライアント側のjavascript - おそらくこれはすでに間違っています。サーバーはプッシュを行うべきですよね？）：

一緒に

しかし、これはまったく機能しません。それから私は使用しました

しかし、やはり目に見える効果はありません。end()また、djangoサーバーへのajax投稿を行う別の関数に置き換えました。しかし、stomp.onclose再び何もせず、window.onbeforeunloadパイプが壊れてしまいます。

したがって、これらは「クライアントが終了する前にメッセージを残す」というアイデアを実装する試みでした。しかし、それは失敗しました。

私がこれを正しく行っているかどうかさえわかりません。ユーザーの離脱についてオービット/ストンプユーザーに通知する方法はありますか? すべてのアイデアをいただければ幸いです。

編集：別の方法があるかもしれません。誰かの接続が閉じられたときに、ユーザーのキーを使用してアプリケーションへの http コールバックを作成するように軌道サーバーを構成できることを読みました。残念ながら、それを行う方法の説明はありませんでした。誰も答えを知っていますか？

シンプルな django/orbited/stomp ライブ チャットのセットアップ方法に関するこのチュートリアルに従っています。よくわからないエラー。

Web サイトにアクセスすると、「エラー」というアラートが表示されます。Firebug のメッセージを見ると、次の 2 つのエラーが表示されます。

チュートリアルをドットまで正確に実行しましたが、これらのエラーが発生する理由がわかりません。私は軌道上を走ります：

そして、次の方法でdjango開発サーバーを実行します。

2か月に1回程度、問題が発生しています。ActiveMQ サーバーが停止し、ログが SocketExceptions でいっぱいです。

ストンプを使用して ActiveMQ にメッセージを送信する PHP アプリケーションと、メッセージを消費する Java アプリケーションがあります。

メッセージの送信/消費時にJavaアプリケーションのみが使用される別のサーバーにactivemqがあり、このように失敗したことはありません。Stompには何か問題があると思います。

ストンプ コードは非常に基本的なもので、奇妙なものは何も送信しません。メッセージ プロパティが設定されたメッセージのみ。ストンプ コードは、メッセージが送信されるたびに接続を閉じます。

lsof を見てきましたが、異常はありません。

ただし、 netstat には次のものがたくさんあります。

tcp6 0 0 127.0.0.1:61616 127.0.0.1:46280 CLOSE_WAIT

そして、ActiveMQ ログは、この多くを示しています

2011-04-28 12:43:09,819 | エラー | 接続を受け入れることができませんでした: java.net.SocketException: 開いているファイルが多すぎます | org.apache.activemq.broker.TransportConnector | ActiveMQ トランスポート サーバー: tcp://0.0.0.0:61616

私は使用しています：

ActiveMQ 5.4.2、Tomcat 6.0.20、Debian 5.0.3、PHP 5.2.6、Stomp リビジョン 43

Orbitedを開始しようとしていますが、残念ながら、いくつかの問題が発生しています。まず、easy_installの問題（解決済み）。次に、http：//mischneider.net/？p=125からの指示に進みます。しかし、使用するorbited -c orbited.cnfと次のようになります。

そして、これが私の設定ファイル（orbited.cnf）です：

（編集：[format]セクションが必要な場合がありますか？）私にはまったく何もありません。私が見つけたリソースのほとんどは、orbited.orgを指しています。お願い助けて！私は本当にクールなライブdjangoアプリに取り組み始めたいです！

http://mischneider.net/?p=125の指示に従って Orbited を実行しようとしています。

エラーのコピーは次のとおりです。

また、ページをロードするとエラーが発生します。ここに私のファイルのいくつかの選択があります。

index.html:

orbited.cnf

URL:

私の問題がどこかにあることを願っていますか？助けてくれてありがとう:D