CentOS 7.9 における RabbitMQ インストールガイド

CentOS 7.9 における RabbitMQ インストール手順 本記事では、CentOS 7.9 に RabbitMQ をインストールする手順を詳しく解説します。 1. RPM パッケージのダウンロード 1.1. Erlang のダウンロード RabbitMQ は Erlang に依存しているため、まず Erlang をインストールする必要があります。 wget --content-disposition "https://packagecloud.io/rabbitmq/erlang/pack ...

7月31日 05:56 投稿

.NET Core で Apache Kafka を利用した信頼性のあるメッセージ処理実装

オフセット管理を活用した重複処理防止の実装 Apache Kafka を .NET Core で利用する際、コンシューマーがメッセージを受信した後、Kafka が停止/再起動した際に重複処理が発生する問題があります。この問題を解決するため、Redis を活用したオフセット管理を実装します。 問題の背景 コンシューマーがメッセージを受信後、StoreOffset() を呼び出してオフセットを確認しま ...

7月31日 01:00 投稿

RabbitMQのメッセージ送信と受信(PHP版)

RabbitMQの基本概念 RabbitMQは、メッセージを受信し、転送する代理です。郵便局に例えると、RabbitMQはメールを受信し、保存し、受信者に転送する機能を担います。 以下はRabbitMQで使用されるいくつかの用語です: Producer(送信者):メッセージを送信するプログラム。 Queue(キュー):RabbitMQ内部のメッセージを保存するバッファ。 Consumer(受信者):メッセー ...

7月23日 16:37 投稿

Spring BootとRabbitMQを用いた支払い結果通知システムの実装

RabbitMQ設定クラス @Configuration public class PaymentNotificationConfig implements ApplicationContextAware { public static final String PAYMENT_EXCHANGE = "payment_exchange"; public static final String NOTIFICATION_TYPE = "payment_result"; public static final String NOTIFICATION_QUEUE = "payment_notification_queue"; @Bean(PA ...

7月22日 23:05 投稿

RabbitMQのExchangeとDead Letter QueueおよびDelayed Queueの実践ガイド

Exchangeの基礎と種類 Exchangeとは RabbitMQのメッセージングモデルにおいて、プロデューサーはメッセージを直接キューに送信しません。プロデューサーはExchangeにメッセージを送信し、Exchangeがルーティングルールに基づいてキューにメッセージを配信します。 Exchangeの種類 Direct Exchange ルーティングキーと完全一致するキューにメッセージを配信します。例え ...

6月1日 19:37 投稿

Spring BootにおけるRabbitMQ設定の詳細解説

接続設定 spring: rabbitmq: host: rabbitmq-server port: 5672 username: admin password: securepass connection-timeout: 15000 virtual-host: / requested-heartbeat: 60 publisher-confirms: true publisher-returns: true リスナー設定 spring: rabbitmq: listener: simple: prefetch: 1 concu ...

5月18日 05:54 投稿