var amqp = require('amqplib');connect([url, [socketOptions]])var amqp = require('amqplib/callback_api');connect([url, [socketOptions]], function(err, conn) {...})url 中的参数可以在URI的查询部分中给出进一步的AMQP调整参数，例如，如'amqp://localhost?frameMax=0x1000'。这些是：frameMax连接上允许的最大帧的大小（以字节为单位）。0意味着没有限制（但是因为帧的大小字段是无符号的32位整数，所以它是perforce 2^32 - 1）; 我将其默认为0x1000，即4kb，这是允许的最小值，适合多种用途，而不是通过Node.JS的缓冲池。channelMax允许的最大通道数。默认是 0，意思是2^16 - 1。heartbeat连接心跳的周期，以秒为单位。默认为0;locale错误消息的所需区域设置。RabbitMQ只使用过en_US; 幸运的是，这是默认的。url 也可以作为对象使用{protocol: 'amqp',hostname: 'localhost',port: 5672,username: 'guest',password: 'guest',locale: 'en_US',frameMax: 0,heartbeat: 0,vhost: '/',}
/
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！
