RabbitMQ tutorial - Publish/Subscribe | RabbitMQ
PrerequisitesThis tutorial assumes RabbitMQ is installed and running on localhost on the standard port (5672). In case you use a different host, port or credentials, connections settings would require adjusting. Where to get helpIf you're having trouble going through this tutorial you can contact us through GitHub Discussions or RabbitMQ community Discord. In the previous tutorial we created a w
Dead Letter Channel Pattern with RabbitMQ
メッセージングシステムで送信されたメッセージが正常に処理されなかった場合どうするのか? RabbitMQ 2.8 以降では expire したメッセージや拒否されたメッセージを dead letter として専用の exchange に転送する事ができる。 dead letter になるユースケース 以下のケースで、メッセージは dead letter になる The message is rejected (basic.reject or basic.nack) with requeue=false The TTL for the message expires Enterprise Integratin Patterns との対比 Gregor Hohpe & Bobby Woolf の “Enterprise Integratin Patterns” では 前者は Invalid M
Dead Letter Exchanges | RabbitMQ
What is a Dead Letter Exchange Messages from a queue can be "dead-lettered", which means these messages are republished to an exchange when any of the following four events occur. The message is negatively acknowledged by a consumer using basic.reject or basic.nack with requeue parameter set to false, or The message expires due to per-message TTL, or The message is dropped because its queue excee
Decompose That WAR! Architecting for Adaptability, Scalability, and Deployability
Decompose That WAR! Architecting for Adaptability, Scalability, and Deployability It’s no longer acceptable to develop large, monolithic, single-language, single-framework Web applications. In this session, you will learn how to use the scale cube to decompose your monolithic Web application into a set of narrowly focused, independently deployable services. The presentation discusses how a modular
RabbitMQ 3.1の導入とCluster構成を検証する
RabbitMQ 3.1の導入と冗長化の検証をしたのでメモ。 検証のための構成はフロントのAPサーバー、RabbitMQが動作するキューサーバー、ワーカーそれぞれ二台づつ。キューサーバーが片方死んでも全体が動作し続けられる事、両方がダウンしたとしてもデータは損失しない事が確認できれば良い。要するに単一障害点にならないようにRabbitMQを使いたい。 サーバーの準備 仮想マシン6台はVagrantを使えば一発で用意できる、メモリ16GB積んでてよかった。ホスト名を後でいじるとrabbitmqctlで停止・再起動がうまくいかなくなった。ホスト名周りはEC2で使う時に面倒な事になりそうだ。 各サーバーの /etc/hosts にrabbit1とrabbit2は追加しておく。 RabbitMQ 3.1 のインストール 起動確認 vagrant@rabbit1:~$ sudo rabbitmq-s
Shovel Plugin | RabbitMQ
Overview This guide provides an overview of RabbitMQ Shovel, a core RabbitMQ plugin that unidirectionally moves messages from a source to a destination. Two more guides cover the two flavors of Shovels, dynamic shovels and static shovels, respectively. This one focuses on explaining the concept, how do shovels work and what they can do. Sometimes it is necessary to reliably and continually move m
RabbitMQ tutorial - Work Queues | RabbitMQ
PrerequisitesThis tutorial assumes RabbitMQ is installed and running on localhost on the standard port (5672). In case you use a different host, port or credentials, connections settings would require adjusting. Where to get helpIf you're having trouble going through this tutorial you can contact us through GitHub Discussions or RabbitMQ community Discord. In the first tutorial we wrote programs
Management Plugin | RabbitMQ
Prefer external monitoring options where possible. Infrastructure and kernel-level monitoring is also crucially important to have in any production system. The management UI and its HTTP API is a built-in monitoring option for RabbitMQ. This is a convenient option for development and in environments where external monitoring is difficult or impossible to introduce. However, the management UI has a
RabbitMQ Performance Measurements, part 2 | RabbitMQ
Welcome back! Last time we talked about flow control and latency; today let's talk about how different features affect the performance we see. Here are some simple scenarios. As before, they're all variations on the theme of one publisher and one consumer publishing as fast as they can. Some Simple Scenarios This first scenario is the simplest - just one producer and one consumer. So we have a ba
AWSを活用したリアルタイム広告の入札・配信・ログ解析 #hcj13w
Hadoop Conference Japan 2013 Winter で発表した資料です。 http://hcj2013w.eventbrite.com/ 『AWSを活用したリアルタイム広告の入札・配信・ログ解析』 講演者: 安田 崇浩, ソネット・メディア・ネットワークス株式会社 最近のインターネット広告では、複数の広告会社が1ページビュー毎にオークションに参加して広告を配信するリアルタイムビッディングという取引が行われています。日本でも1秒間に数万件以上の取引が行われており、弊社も参加しています。最適な広告を配信するために、オークション取引や落札後の広告配信のログをMessagePack/RabbitMQで処理し、AmazonS3、Elastic Map Reduce、DynamoDB 等のAmazon Web Servicesを活用して分析しています。オークション取引、広告配信で利
RabbitMQ と再送について
概要 : AMQP のプロトコルを読むと、一瞥して送信はパケットを送るだけ、受信はソケットを読み込むだけのようにも見える。しかしながら、実際に書いてみると、再送処理を自前で実装する必要があるため、現実には大変に複雑な処理が必要だ。 そもそもなぜ RabbitMQ を使うのかという話、あるいはなぜ再送が必要かという話たんにコンポーネント同士が疎結合で通信したいのであればわざわざ MQ を使う必然性は皆無である。ごくあたりまえに TCP で通信すればそれでいい。暗号通信が必要なら当然 SSL でいいし、パケットエンティティに依存する複雑な L7 リバースプロキシを MQ を使って実現することも、不可能ではないが、普通そういうのは varnish とかでやるだろう。 MQ において優れているのはデータの durability だ。つまり、一旦キューにためておけば、その両側のコンポーネントは好き勝
『はじめての RabbitMQ』
アメーバ事業本部 API 基盤グループでプログラマをしている @na_ga です。 API 基盤グループでは、弊社の様々なサービスから利用される共通 API の開発・運用を行なっております。今回は、私が担当した API でメッセージキューとして利用した RabbitMQ を紹介させていただきたいと思います。 はじめにAPI 基盤グループで提供している API には、リクエストをリアルタイムに処理する必要がないものもあります。例えばメール配信 API や、投稿内容の有人監視 API などが挙げられます。 これらの非同期処理が可能な API では、大量のリクエストを受け取るためにメッセージキューを使用しています。 メッセージキューを使用した構成では、リクエストを受け取るプログラムが、受け取ったリクエストから生成したメッセージをキューに格納します。キューに格納されたメッセージは、メッセージを処理
Tools and Technology I’d Like To Use
This is a short list of technology and tools that I’ve been looking at off and on over the last few months and would like to try out to solve real problems (not just toy projects). RabbitMQ, because queuing make a lot more sense that polling in a lot of applications. 0MQ, because I like the higher level network connection abstractions. Hadoop (probably from Cloudera), because we have a lot of mach
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - rabbitmq/rabbitmq-consistent-hash-exchange: RabbitMQ Consistent Hash Exchange Type
GitHub - mikehadlow/EasyNetQ: An easy to use .NET API for RabbitMQ
Getting Started With RabbitMQ in .net – Part 3
rabbitmq-tutorials/dotnet at main · rabbitmq/rabbitmq-tutorials
RabbitMQ
Using RabbitMQ with C# and .NET
