上云无忧 > 文档中心 > 天翼云分布式消息服务RabbitMQ使用Java生产消息
分布式消息服务RabbitMQ
天翼云分布式消息服务RabbitMQ使用Java生产消息

文档简介:
String message = "Hello rabbitMQ!" + i; channel.basicPublish("交换器名称", "路由键", null, message.getBytes(StandardCharsets.UTF_8));
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

 String message = "Hello rabbitMQ!" + i;

            channel.basicPublish("交换器名称", "路由键", null, message.getBytes(StandardCharsets.UTF_8));

相似文档
  • 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);
  • 普通方式: 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");
  • 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实例,并查看状态,状态说明如下
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部