以下に、RabbitMQ接続を閉じるためのシンプルで簡単な方法といくつかのコード例を示します。
- Node.jsの場合:
const amqp = require('amqplib');
async function closeConnection() {
const connection = await amqp.connect('amqp://localhost');
// 接続に関する処理
await connection.close();
console.log('RabbitMQ接続が正常に閉じられました。');
}
closeConnection().catch(console.error);
- Pythonの場合:
import pika
def close_connection():
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
# 接続に関する処理
connection.close()
print('RabbitMQ接続が正常に閉じられました。')
close_connection()
上記のコード例では、amqplib
モジュールを使用してNode.jsでの接続閉じる方法と、pika
モジュールを使用してPythonでの接続閉じる方法を示しています。接続を閉じるためには、接続オブジェクトのclose()
メソッドを呼び出すだけで十分です。
この方法を使用すると、RabbitMQとの接続を適切に閉じることができます。必要に応じて、アプリケーションの終了時に接続を閉じるように処理を追加することもできます。