RabbitMQ+Java まとめ - Qiita
はじめに 忘れないようにRabbitMQを使用したメッセージキューイングの方法をまとめました。 随時更新していく予定です。 RabbitMQの構築については、ここを参照してください。 構築されている前提で進みます。 環境 Java8 Eclipse 4.5 Windows10 Erlang 19.2 RabbitMQ 3.6.6 RabbitMQ使用前に知っておくと楽なこと AMQPの基礎 プロデューサー(Producer) メッセージの送信を行うプログラムを指します。 コンシューマ(Consumer) メッセージの受信を行うプログラムを指します。 キュー(Queue) メッセージを保存しておく箱です。 RabbitMQの内部に存在します。 コンシューマにメッセージを送信する役割も持っており、送信順は先入れ先出しです。 キュー毎に複数のコンシューマを持つことも可能です。 各コンシューマには
RabbitMQ+Java まとめ - Qiita
はじめに 忘れないようにRabbitMQを使用したメッセージキューイングの方法をまとめました。 随時更新していく予定です。 RabbitMQの構築については、ここを参照してください。 構築されている前提で進みます。 環境 Java8 Eclipse 4.5 Windows10 Erlang 19.2 RabbitMQ 3.6.6 RabbitMQ使用前に知っておくと楽なこと AMQPの基礎 プロデューサー(Producer) メッセージの送信を行うプログラムを指します。 コンシューマ(Consumer) メッセージの受信を行うプログラムを指します。 キュー(Queue) メッセージを保存しておく箱です。 RabbitMQの内部に存在します。 コンシューマにメッセージを送信する役割も持っており、送信順は先入れ先出しです。 キュー毎に複数のコンシューマを持つことも可能です。 各コンシューマには
RabbitMQ のインストール - Carpe Diem
概要 RabbitMQをUbuntuにインストールします。 環境 Ubuntu 14.04 RabbitMQ 3.5.6 インストール publicキーの登録 $ wget https://www.rabbitmq.com/rabbitmq-signing-key-public.asc $ sudo apt-key add rabbitmq-signing-key-public.asc パッケージリストを更新してインストール $ echo "deb http://www.rabbitmq.com/debian testing main" | sudo tee /etc/apt/sources.list.d/rabbitmq.list $ sudo apt-get update $ sudo apt-get install rabbitmq-server 管理ツールの導入 プラグインの有効化
rabbitmqを介したsensu-serverとsensu-clientの連携 - Qiita
http://sensuapp.org/ sensuは、2012-2013年ごろに登場した監視フレームワークで、nagiosの問題点を解決しうるモダンな設計を搭載して注目されている. 日本でもスタートアップでの採用事例が増えている点とrubyで実装されている点を考慮してsensuを導入してみることにした. sensuの基本構成 sensuを導入するといろんなものがインストールされていろんなプロセスが立ち上がるが、この中で実際に監視業務をおこなっているのはsensu-client, sensu-serverの2つ. この両者がrabbitmqを介してどのようにメッセージのやりとりを行っているか理解することでsensuの概要が見えてくる. SENSU SERVER: 監視サーバ SENSU CLIENT: 監視対象サーバ 図１ rabbitmq概要 https://www.rabbitmq.c
amqpを使ってRabbitMQのキューを操作する - Qiita
使用するバージョン RabbitMQ 3.3.5 amqp 1.5.0 条件 vhostは/production ユーザはuser1、パスワードはpassとする キューにメッセージを追加する（基本） # -*- coding: utf-8 -*- require 'amqp' # RabbitMQに接続 AMQP.start(:host => "localhost", :vhost => "/production", :user => "user1", :pass => "pass") do |connection, open_ok| # channelを作成 channel = AMQP::Channel.new(connection) # queue1というキューを作成 # キューが無い場合は作成（既にある場合もエラーにはならない） queue = channel.queue("que
RabbitMQのインストールと管理画面の有効化(MacOSX/Linux/Windows) - Qiita
RabbitMQのインストールとRabbitMQ管理画面の有効化までのステップのメモ Mac OSX 一番簡単 brew install rabbitmq 以上でインストール終了。裏でいろいろ(下で実施するLinuxインストール相当のことを)やってくれてる。 にアクセスすると管理画面が有効になっている。 user:guest password:guest でログインできる Erlangをインストール sudo yum install erlang RabbitMQをダウンロード RPMはこちらから http://www.rabbitmq.com/install-rpm.html curl -O http://www.rabbitmq.com/releases/rabbitmq-server/v3.4.4/rabbitmq-server-3.4.4-1.noarch.rpm RabbitMQ
RabbitMQ チュートリアル１（"Hello World!"） - Qiita
RabbitMQのチュートリアル１ https://www.rabbitmq.com/tutorials/tutorial-one-python.html の翻訳です。 翻訳の誤りなどあればご指摘お待ちしております。 前提条件 このチュートリアルでは、RabbitMQのがインストールされ、ローカルホストの標準のポート（5672）上で実行されている前提とします。別のホスト、ポート、または資格情報を使用する場合には、接続設定の調整が必要です。 問題が発生した場合 このチュートリアルを通して問題が発生した場合、メーリングリストを通して私たちに連絡することができます。 はじめに RabbitMQは、メッセージ·ブローカーです。主なアイデアは非常に単純です：メッセージを受け付け、そして送り届けます。それは郵便局と考えることができます：あなたはポストに手紙を出すとき、郵便配達員が最終的には受取人に配達
RabbitMQ + Paho-Golang-ClientでMQTTを始める - blog::wnotes.net
MQTT始めました リアルタイムWebという言葉をたまに聞きますが、WebSocketから始まり、WebRTCもやったし、次はMQTTやろうと思ったので、環境構築と簡単な動作メモを残します。 MQTTって何？ 他のエントリで詳しく書かれているので、そちらを参照してください。↓のリンクは大体の人が見てると思います。 MQTTについてのまとめ -そこはかとなく書くよん。 以前WebRTCの発表をした時にもワードは観測していたのですが、ここ最近良く聞く用になってきたし、モバイル向けの配信基盤として有用なんじゃないかなって思います。 今回は、MQTTブローカーとしてRabbitMQ、Publish/SubscribeクライアントとしてPahoのgolangクライアントを使いました。 Rabbit MQ Paho PahoはGolang以外にもJavaScriptやPython、C++もあるので、色
RabbitMQ の mqtt プラグインを Ruby で試した | iret.media
AMQP を使用したメッセージキューを扱うミドルウェア Erlang で記述されている OTP フレームワークで構築されている Erlang や OTP についてはこちらの「Introduction | Learn You Some Erlang for Great Good!」が詳しく書かれているので読んでみたいと思います。 こちらの「MQTTについてのまとめ」に詳しく書かれておりとても参考になりました。 内容を個人的に簡単に要約すると… MQ Telemetry Transport pub/sub モデルの軽量なメッセージプロトコル メッセージ配信に特化している 沢山の pub/sub を扱う場合に使われている（リアルタイム通信が必要な時等） センサーデバイスからのデータ収集 Facebook Messenger 等のメッセージサービス mqtt は以下のような特徴があります。 固定長
『はじめての RabbitMQ』
アメーバ事業本部 API 基盤グループでプログラマをしている @na_ga です。 API 基盤グループでは、弊社の様々なサービスから利用される共通 API の開発・運用を行なっております。今回は、私が担当した API でメッセージキューとして利用した RabbitMQ を紹介させていただきたいと思います。 はじめにAPI 基盤グループで提供している API には、リクエストをリアルタイムに処理する必要がないものもあります。例えばメール配信 API や、投稿内容の有人監視 API などが挙げられます。 これらの非同期処理が可能な API では、大量のリクエストを受け取るためにメッセージキューを使用しています。 メッセージキューを使用した構成では、リクエストを受け取るプログラムが、受け取ったリクエストから生成したメッセージをキューに格納します。キューに格納されたメッセージは、メッセージを処理
AMQPによるメッセージング | GREE Engineering
こんにちは。GREEのプラットフォーム開発部でインフラ系の仕事をしているmdoi(@m_doi)と申します。よろしくお願いします。今回は、AMQPについて簡単に紹介したいと思います。 はじめに GREEで稼働中のサーバは、日々サーバの異常ログ、自己監視結果、メール等々、大量のメッセージをやり取りしています。しかしながら、共通のメッセージングインフラが存在しないため、それぞれが独立に色々なメッセージ送信を行っています。 サーバ台数の増大に伴って、メッセージ配送の負荷が無視できないレベルになって来ると、それらのメッセージングシステムについて、個別に負荷対策を施すなど運用上様々な問題が課題が出てきます。また、メッセージの種類によっては、その配送の仕組がスケーラビリティに欠けるものとが存在し、規模の増大に対応できなくなる恐れもあります。そのため、こういうった用途に使えるスケーラブルなメッセージング
RabbitMQ のドキュメントを拾い読みしたのでメモと Ruby から RabbitMQ を使う Bunny を試してみた | iret.media
ども、cloudpack の かっぱ（@inokara）です。 はじめに RabbitMQ について改めて勉強したくなったので各種ドキュメントを斜め読みして纏めてみました。間違い等あれば修正リクエスト頂ければ幸いです。 RabbitMQ と AMQP RabbitMQ がサポートしている AMQP のバージョン Compatibility and Conformance RabbitMQ がサポートしている AMQP のバージョンは AMQP 0-9-1 AMQP 0-9 AMQP 0-9 となります。AMQP 0-9-1 の利用が推奨されています。 RabbitMQ がサポートしているメッセージングプロトコル Which protocols does RabbitMQ support? 以下のようなメッセージングプロトコルをサポートしているようです。 STOMP(Simple Text
RabbitMQ インストールや操作メモ、ちょっと濃い話 | cloudpack.media
ども、cloudpack の かっぱ (@inokara) です。 CentOS にインストール 環境 CentOS 6.5 iptables を止めておく selinux も disabled Security Group で VPC 内のサブネット通信はすべて許可した（必要に応じてポートは絞りましょう） epel パッケージリポジトリの登録からのインストール デフォルトの状態だと epel のリポジトリは非登録なのでひとまず。 sudo rpm -i http://dl.fedoraproject.org/pub/epel/6/x86_64/epel-release-6-8.noarch.rpm からの… sudo yum -y install erlang rabbitmq-server --enablerepo=epel でとりあえず…。 sudo /etc/init.d/rabb
MongoDB as Message Queue
Designing Apache Hudi for Incremental Processing With Vinoth Chandar and Ethan Guo | Current 2022 Back in 2016, Apache Hudi brought transactions, change capture on top of data lakes, what is today referred to as the Lakehouse architecture. In this session, we first introduce Apache Hudi and the key technology gaps it fills in the modern data architecture. Bridging traditional data lakes and wareho
分散型メッセージングミドルウェアの詳細比較 | POSTD
メッセージキュー について書いている連載の続きとして、今週末は分散型メッセージングを実行するための様々なライブラリを詳細に分析していきたいと思います。今回の分析では、APIの特性、デプロイメントやメンテナンスの容易さ、そしてパフォーマンスの質を含めて2、3種類の異なる側面に着目します。メッセージキューは2つのグループに分類できます。ブローカレス（brokerless）とブローカード（brokered）です。ブローカードなキューはエンドポイント間に何かしらのサーバを挟んでいますが、ブローカレスなメッセージキューは、メッセージ送信の際でも間に何も挾まないP2Pです。 今回分析するのは以下のシステムです。 ブローカレス nanomsg ZeroMQ ブローカード ActiveMQ gnatsd Kafka Kestrel NATS NSQ RabbitMQ Redis 取り掛かりとして、ほぼ間違
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
https://qiita.com/inokappa/items/5b084049881cddd8b84e
https://qiita.com/inokappa/items/795d43661541a85a09c0
AMQP/RabbitMQ
RabbitMQ のクラスタリング、HA メモ
涙の自腹課金検証シリーズ第一弾：RabbitMQ クラスタ HA モード 3 パターンを速攻試す