天翼云分布式消息服务RabbitMQ使用Java消费消息

分布式消息服务RabbitMQ

简介/价格/文档

天翼云分布式消息服务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);

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

免费试用、价格特惠

文档详情

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");
天翼云分布式消息服务RabbitMQ使用C\C++代码示例
C\C++API 创建连接 char const *hostname; int port, status; amqp_socket_t *socket; amqp_connection_state_t conn; conn = amqp_new_connection(); socket = amqp_ssl_socket_new(conn); amqp_ssl_socket_set_verify_peer(socket, 0); amqp_ssl_socket_set_verify_hostname(socket, 0);
天翼云分布式消息服务RabbitMQ购买实例
购买实例登录管理控制台。进入RabbitMQ管理控制台。在管理控制台右上角单击“地域名称”，选择区域。此处请选择与您的应用服务相同的区域。点击“购买实例”跳转到购买页面。
天翼云分布式消息服务RabbitMQ查看实例
查看实例登录管理控制台。进入RabbitMQ管理控制台。当前页面会列出所购买的RabbitMQ实例，并查看状态，状态说明如下
天翼云分布式消息服务RabbitMQ创建和删除虚拟主机
创建和删除虚拟主机 Vhost 虚拟主机（Virtual Host），类似于 Namespace 命名空间的概念，逻辑隔离，每个用户里可以创建多个 Vhost，每个 Vhost 可以创建若干个 Exchange 和 Queue。 1.登录管理控制台。 2.进入RabbitMQ管理控制台。

文档中心

全民上云·上云补贴申领

免费试用（限企业）