天翼云分布式消息服务RabbitMQ使用Java关闭连接

分布式消息服务RabbitMQ

简介/价格/文档

文档简介：

connection.close();·

*产品来源：中国电信天翼云。免费试用咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！微信咨询

connection.close();

相似文档

天翼云分布式消息服务RabbitMQ使用Java创建信道
Channel channel = connection.createChannel();
天翼云分布式消息服务RabbitMQ使用Java关闭信道
channel.close();
天翼云分布式消息服务RabbitMQ使用Java生产消息
String message = "Hello rabbitMQ!" + i; channel.basicPublish("交换器名称", "路由键", null, message.getBytes(StandardCharsets.UTF_8));
天翼云分布式消息服务RabbitMQ使用Java消费消息
Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, StandardCharsets.UTF_8); System.out.println(" [x] Received '" + message + "'"); } }; channel.basicConsume("队列名称", true, consumer);
天翼云分布式消息服务RabbitMQ使用Java代码示例
普通方式： ConnectionFactory factory = new ConnectionFactory(); // 设置连接地址，可在控制台概览->节点查看，推荐用vip，vpc内可使用vpcIp factory.setHost("vip_address,ex:192.168.90.2"); factory.setPort(5671); // 设置用户名密码，需要在控制台先创建 factory.setUsername("username"); factory.setPassword("password");

文档中心