나는 amqplib을 node.js와 함께 사용하고 있으며, 나는 channels
이라는 개념을 확실히 이해하려고 노력하고 있습니다.amqp rabbitmq 채널 범위
var amqp = require('amqp/callback_api');
var connection = amqp.createConnection({ host: "localhost", port: 5672 });
connection.on('ready', function() {
connection.createChannel(function(err, ch) {
ch.assertExchange('1', 'fanout', function(err, ok) {});
ch.assertQueue('a', {
exclusive: true,
durable: true
}, function(err, ok) {
});
});
위의 경우 : 여기
Channels are multiplexed over connections, and represent something like a session, in that most operations (and thereby most errors) are scoped to channels.
내가하는 AMQP 연결을 열 채널, 교환 및 대기열을 생성 할 기본 코드 :
이것은 amqplib 문서에서입니다 코드는 exchange '1'
과 queue 'a'
이 정의 된 채널에만 존재합니까? 이 말은 내가 교환 할 메시지를 다른 채널의 a
에 게시하면 a
은 여전히 메시지를 전달한다는 뜻입니까?