生まれ変わった「Days of Liris」。プログラミングのこと、Pythonのこと、気になったソフトウェアのこと、身の回りのこと、いろんなこと。など 前回の続きです。 AMQPの構成要素 メッセージブローカー:AMQPクライアントが接続するサーバ(サーバはクラスタ構成にできるが仕様書は規定しない) 交換(Exchange)とキューで構成 ユーザ: IDとパスワードでブローカーに認証して接続するもの。 コネクション: TCP/IPなどを使っての物理的な接続。各コネクションはユーザと結びつけられる。 チャネル: 論理的なコネクション。 ステートフル 各コネクションでの並列実行する時は、スレッドごとに別のチャネルで操作 メッセージを送受信するエンティティはチャネル上に宣言 一度宣言したエンティティを別のプロパティに変更しようとするとエラー プロパティの変更は一度削除してから エンティティは名
Tweet Follow @RabbitMQ April 16, 2015For a while people have looked for ways of implementing delayed messaging with RabbitMQ. So far the accepted solution was to use a mix of message TTL and Dead Letter Exchanges as proposed by James Carr here. Since a while we have thought to offer an out-of-the-box solution for this, and these past month we had the time to implement it as a plugin. Enter RabbitM
はじめに モジュール間連携のイベントバスとして RabbitMQ を使用したいのですが,クラスタを組む場合にどうするのが良いのかな?ということを調べてみました *1. なお,以降では「CAP のうち CP 特性が欲しい」ということを念頭において調査しています. 動作確認について RabbitMQ は 3.6.1 です.ローカルのマシンに VM を起動して動作確認しています. https://github.com/krdlab/examples/tree/master/distributed-rabbitmq-brokers RabbitMQ の分散構成について 分散構成に関する公式の情報は以下の通りです. https://www.rabbitmq.com/distributed.html https://www.rabbitmq.com/clustering.html https://ww
This document discusses messaging queues and platforms. It begins with an introduction to messaging queues and their core components. It then provides a table comparing 8 popular open source messaging platforms: Apache Kafka, ActiveMQ, RabbitMQ, NATS, NSQ, Redis, ZeroMQ, and Nanomsg. The document discusses using Apache Kafka for streaming and integration with Google Pub/Sub, Dataflow, and BigQuery
Message ordering guarantees Section 4.7 of the AMQP 0-9-1 core specification explains the conditions under which ordering is guaranteed: messages published in one channel, passing through one exchange and one queue and one outgoing channel will be received in the same order that they were sent. RabbitMQ offers stronger guarantees since release 2.7.0. Messages can be returned to the queue using AMQ
tl; dr 分散オブジェクトプログラミングなdRuby入門 dRubyで分散負荷試験のサンプルコード はじめに dRubyってご存知でしょうか。標準ライブラリdrbとしてRubyに同梱されていて、 分散オブジェクトプログラミングのためのライブラリです。 Ruby のプロセスから他のRubyプロセスにあるオブジェクトのメソッド を呼びだすことができます。他のマシン上のプロセスにも アクセスできます。 と説明されています1。純Rubyな標準ライブラリなのでRubyさえ動けば簡単に分散プログラミングすることができます。 dRubyを使って分散負荷試験をやってみたらとても楽ちんだったので紹介します。 RabbitMQの負荷試験をするためにdRubyを使いましたが、Webでもなんでも使える汎用的な仕組みです。 環境 この記事のコードは次の環境で動作確認をしています。 MacOS X 10.11.1
These tutorials cover the basics of creating messaging applications using RabbitMQ. You need to have the RabbitMQ server installed to go through the tutorials, please see the installation guide or use the Docker image. Executable versions of these tutorials are open source, as is this website. These tutorials focus on just one (the original) protocol supported by RabbitMQ. Examples for RabbitMQ st
本当は昨日書こうと思ってたが、忘年会だしその日の記事は忘れることにした。 RabbitMQ自体は基本的にメッセージを送って受け取るという簡単なもので、そんなに難しくない。 ただ実運用に載せるにあたってはRabbitMQ / AMQPにおける用語や概念を理解したり、調査したり、理解が出来たら次はその中からどの手段を使うか選んだりしないといけない。ここでは個人的に自分が理解に苦労したなーと思う用語の説明をまとめておこうと思う。 ラウンドロビン まずラウンドロビンという言葉を知らなかったのは不勉強から来るものだったが、それがRabbitMQで何を意味するのかを理解するのに時間がかかった。単に「あるQueueに接続しているConsumerが複数あったらメッセージを持ってないConsumerから先にどんどんメッセージを突っ込む。」という程度の意味だ。 RabbitMQはpre-fetchといって一度
メッセージキュー について書いている連載の続きとして、今週末は分散型メッセージングを実行するための様々なライブラリを詳細に分析していきたいと思います。今回の分析では、APIの特性、デプロイメントやメンテナンスの容易さ、そしてパフォーマンスの質を含めて2、3種類の異なる側面に着目します。メッセージキューは2つのグループに分類できます。ブローカレス(brokerless)とブローカード(brokered)です。ブローカードなキューはエンドポイント間に何かしらのサーバを挟んでいますが、ブローカレスなメッセージキューは、メッセージ送信の際でも間に何も挾まないP2Pです。 今回分析するのは以下のシステムです。 ブローカレス nanomsg ZeroMQ ブローカード ActiveMQ gnatsd Kafka Kestrel NATS NSQ RabbitMQ Redis 取り掛かりとして、ほぼ間違
eXcale開発チームの泉谷(@syguer)です。 今回はMessage QueuingのためのミドルウェアであるRabbitMQについて紹介します。 eXcaleでは、裏側の仕組みとして各コンポーネントがメッセージでやり取りをするようにしています。 それによってコンポーネント同士を疎結合にすることができます。また非同期処理により処理全体の効率化を実現しています。 RabbitMQはその中核となっています。 RabbitMQとは RabbitMQはメッセージキューイングのためのミドルウェアです。オープンソースで公開されています。 もともとはRabbit Technologies社が開発していたものですが、現在はPivotal Softwareのもとで開発されているようです。 RabbitMQ公式サイト http://www.rabbitmq.com/ RabbitMQでは
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く