問題タブ [mosca]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
0 に答える
1775 参照

angularjs - AMQJSC0001E Paho から mosca への接続中に接続タイムアウト・エラーが発生しました

私はIoTの世界に慣れていないので、FEでpahoを使用して、mqttプロトコルを介してサーバーに接続しようとしています。バックエンドは node にあり、mosca はブローカーです。angularjs app から top を聴こうとすると、次のメッセージが表示されます。

そして mqttClient.connect ->onFailure で、このエラー obj を取得します

c:\nodejsPrjct>node server.js

server.js コンテンツ


angular.js から >

*反対票を投じる方は、説明して反対票を投じてください。

0 投票する
1 に答える
401 参照

node.js - mosca: SyntaxError: 予期しない識別子

Ubuntu 14.04 LTSのnodejsでMQTTサーバーを実行しようとしていました

次のエラーがスローされます。

誰かが私が間違っていることを助けることができますか?

0 投票する
2 に答える
2270 参照

node.js - ブラウザから HTTPS を使用して Web ソケット経由で mqtt クライアントに接続します

HTTPS による Web ソケットを使用して、Web ブラウザーで mqtt クライアントを実行したいと考えています。HTTP では問題ありません。HTTP を使用する場合の Web ブラウザー上のコードは次のとおりです。

これは、スタンドアロンの mosca ブローカーを起動して Websocket で HTTPS を使用する方法です。

HTTPS 経由で Websocket 上の Mosca ブローカーに接続するには、ブラウザーの mqtt クライアント コードをどのように変更すればよいですか?

0 投票する
1 に答える
2747 参照

mqtt - Mosquitto と Mosca の水平方向のスケーラビリティと回復力は?

Mosca または Mosquitto ブローカー (オープン ソースであるため) を使用して、メッセージ キューのレプリケーションを備えたスケーラブルなアーキテクチャを実現し、ブローカーの最終的な障害時にブローカーによってまだ配信されていないメッセージが失われないようにすることを計画していました。
私が読んだように、mosquitto は、ブリッジを使用した水平方向のスケーラビリティを備えた、成熟した非常に安定したソリューションです。しかし、データベースにメッセージを書き込むためのプラグインが見つかりませんでした (すべてのブローカーに共通)。つまり、2 つのブローカーが負荷分散され、そのうちの 1 つが停止した場合、このすべてのメッセージが失われるため、これが制限であると思いますブローカーが復旧するまで、ブローカーを配信できません。一方、Mosca では Redis を使用してスケーリングできます。ブローカ 1 が停止した場合でも、ブローカ 2 は共通のデータベースに格納されているため、引き続きメッセージを配信できます。そのようにして、redis のマスター/スレーブ構成を使用して、単一障害点を回避できます。

だから私の質問は:

1) mosca は生産に適していますか?

2) redis を使用して mosquitto でメッセージ キューを割り当てることは可能ですか?

0 投票する
2 に答える
571 参照

node.js - Mosca は複数のメッセージを継続的に送信します

Moscaが実行されているノードjsサーバーをセットアップしました。クライアントは Mosca サーバーに接続してメッセージを発行できます。メッセージの形式で確認を送信する必要があります(トピックにサブスクライブ)。クライアントに返信します。

以下のコードは、メッセージがクライアントによってパブリッシュされると、複数のメッセージを連続して送信します。何か不足していますか?