問題タブ [subscriber]

私はWeb2.0の慣行に追いつくことを試みていましたが、最近、データベースの変更をポーリングしてWebページを非同期的に最新の状態に保つことに関する記事に遭遇しました（スタックオーバーフローが新しいときに通知するのと同様の目的で回答が追加されました）。

これにより、Web上でサブスクライブ/更新の関係を実装できるかどうかを考えました。これが可能かどうか誰かが知っていますか？もしそうなら、それについての良い記事にリンクすることができますか？

また、スタックオーバーフローが非同期更新システムを実装する方法を知っている人はいますか？スタックオーバーフローと同じくらい多くのトラフィックがあるサイトでは、ポーリングは非常に非効率的です。

ここで、サンプルの JMS レイアウトに少し問題があります。

2 台のマシンに 2 つのブローカー (A、B) があり、ネットワーク コネクタを介してリンクされています。プロデューサーは任意のブローカーに送信でき、コンシューマーは任意のブローカーをリッスンでき、送信/受信するトピックはグローバルに利用できるという考えです。

トピックには、トピック内のすべてのメッセージを処理する 2 つの永続サブスクライバー クライアント (各マシンに 1 つ) があります。プロセスを再起動する必要がある場合にプロセスがワークロードを失わないように、永続的なサブスクリプションにしたいと考えています。両方のサブスクライバー クライアントは、フェイルオーバー ブローカーの URL を持つように構成されているため、最初にローカルホスト ブローカーに接続しようとし、他のブローカーに接続できない場合に接続を試みます。クライアントのフェイルオーバーは機能しているようですが、次の状況で問題が見つかりました。

各ブローカ 'A' および 'B' にはサブスクライバ クライアントが接続されています。プロデューサは 'A' に送信しています。ブローカー 'B' が再起動されます。「B」のクライアントは、接続が失われたことを登録し、「A」に切り替えます。'B' が再び表示され、'A' への永続サブスクライバとして登録されているため、メッセージ フィードを取得します。現在、アクティブな永続サブスクライバーはなく ('A' には 'B' を含む 3 つがあります)、接続制限に達するまで積み上げられます。

私の設定は間違っていますか？私が意図したことは可能ですか？

乾杯、カイ

次のシナリオが可能かどうかは正確にはわかりません。

UdpClient または Udp Socket のみを使用して、1 つのパブリッシャーと複数のクライアント環境を実現したいと考えています。

Udp サーバーは、インターネットを介して、隔離されたマシンでブロードキャストしています。1 つまたは複数のクライアントが必要に応じて「購読」または「購読解除」し、ブロードキャストを受信します。

可能ですか？ありがとう。

編集：もしそうなら、回答者は詳しく説明できますか？

編集: サブスクライバーを追跡せずに可能ですか?

追加情報：

既存のクライアント コード:

サーバーもそんなにシンプルにできますか？何か不足していますか？

追加情報: 実際の外部 IP を使用すると、次のエラーが表示されます: この操作を実行する前に Bind メソッドを呼び出す必要があります。

Freeswitch（VOIPソフトウェアスイッチ）のzmqモジュールに接続するために、phpバインディングでzeromqを使用しています。

短い: 私はイベントを失っています。Long: Freeswitch の zmq モジュールは、パブリッシャーとして c++ で実装されています。私のPHPコードは次のとおりです。

ZMQ-Msg-Cnt は、freeswitch の zmq モジュールに組み込んだシーケンス番号です。2 つおきのメッセージが失われていることがわかります。tcpdump は、メッセージが zmq によって受信されたことを示しています。

PHP コードを C に変換したところ、すべてのメッセージを受信できるようになりました。子：

PHPコードに問題はありますか? PHP のトリック/必須/ヒントはありますか?

前もって感謝します、ジェラルド・ウェーバー

APIに、新しいプロファイルの1つのサブスクライバーの数を照会するメソッドはありますか？私は、タイラバンクスの次のような新しいプロファイル（ページではない）について話しています。

http://www.facebook.com/XOXOTYTY

そのページでは、彼女のチャンネル登録者数は696k人（具体的には、プロフィールを検索すると696,833人）であることがわかりますが、グラフにはその数が見つかりません。

/ userId / subscribersがサブスクライバーのリストを提供することは知っていますが（これは素晴らしいです）、クエリしている多くのページには10,000を超えるサブスクライバーがあるため、すべてがリストされているわけではなく、カウントが必要です。

誰かが Magento ニュースレターを購読するときに、姓名も記入してもらいたいです。フォームに 2 つの入力フィールドを追加しました。フィールド名は「firstname」と「lastname」です。

Mage/Newsletter/controllers/SubscriberController.phpを拡張していきます

newAction () で:

ここで投稿変数を取得しました：

成功メッセージの後に次のコードを追加しました。

姓と名のメソッドを機能させたいだけです-setEmail部分は完全に機能します。Model/Subscriber.phpを調べたところ、サブスクライバー名を設定する機能がないことがわかりました。

管理画面のグリッドを見ると、「Customer First Name」と「Customer Last Name」と表示されていることにも気付きました。そのため、これらの名前はサブスクライバー モデルではなく、カスタマー モデルに属していると思います。

これを回避する方法はありますか？ニュースレターを購読するときに、購読者に顧客名を割り当てられるようにしたいと考えています。この投稿に記載されているオブザーバー メソッドを試しましたが、同じ問題が存在すると思います: Magento のサブスクリプション モジュールにカスタム フィールドを追加する

どんな助けでも大歓迎です。

これは Oracle 11.2.0.3 です。

OracleAQ を介して Oracle の JMS を使用する場合に問題が発生します。これは問題なく動作しますが、キューが数千のメッセージでいっぱいになり、時間の経過とともに数百万のメッセージでいっぱいになることに気付き始めました。これらのいくつかは PROCESSED 状態にありますが、ほとんどは READY です。この動作は、「ゾンビ」またはトピックの購読者の死亡にまで遡ることができました。Java プロセスが終了し、それ自体を登録解除する機会が得られない場合、サブスクライバー レコードがキューに残され、Oracle はプロセスが停止していることを検出しないようです。数か月後、マルチサブスクライバー キューに送信された新しいメッセージはサブスクライバーの数で乗算され、実際よりもはるかに多いと見なされます。(これは、登録者数の上限に達したときに初めて気付きました。)

qmon プロセスが実行されています。プロセスの最小数を増やしても効果がありませんでした。キューに死んだサブスクライバがない限り、キューのクリーンアップは非常にうまく行われます。

誰もこれを前に見たことがありますか?うまくいけば解決策を見つけましたか?

クラスタ ノード間の通信を担当する Java JMS アプリケーションを作成しています。メッセージングは​​、トピックを使用して発行/購読によって行われます。TopicSubscriber は、TopicSession.createSubscriber(topic, null, true) を呼び出すことによって作成されます。これは、永続的なサブスクライバーではないことを意味します。現在、サブスクライバーのサブスクライブを解除する (そして接続を閉じるなど) 「リリース」メソッドを実装しています。TopicSession.unsubscribe(String name) は永続的なサブスクライバーにのみ関連することがわかりました。それは必要ですか？

SQL Server 2008R2 トランザクション レプリケーション - SubscriberDB の移動 - サブスクリプションのプッシュ

サブスクライバー データベースをシステム停止の外部にある新しいサーバーに移動する必要があります。つまり、新しいトランザクションがパブリッシャー データベースにロードされるのを止めることができません。

これまでのところ、ディストリビューション エージェントを停止して、レプリケートされていないすべてのコマンドを Server1 のサブスクライバ データベースにレプリケートしようとしました。次に、加入者データベースを Server2 にバックアップおよび復元します。次に、Server2 から既存のパブリケーションへの新しいサブスクリプションを作成しました。

これは機能しますが、その時点以降に作成されたトランザクションのみが Server2 サブスクライバー データベースに複製されます。また、ディストリビュータ データベースで構築されたすべての古いトランザクションが Server1 のみに送信されるようにする必要があります。

ディストリビューターの既存のトランザクションの宛先を新しいsubscriber.subscriber_DBに更新するために使用できるレプリケーション コマンドはありますか?

複数の記事を含む 1 つの出版物があります。パブリケーションは現在、Server1 の 1 つのデータベースによってのみサブスクライブされています。