云服务器内容精选

华为云首页用户手册

步骤三：连接实例生产消费消息

分布式消息服务RabbitMQ版-不使用SSL证书连接:命令行模式连接实例

命令行模式连接实例下载RabbitMQ-Tutorial.zip示例工程代码。 $ wget https://dms-demo.obs.cn-north-1.myhuaweicloud.com/RabbitMQ-Tutorial.zip 解压RabbitMQ-Tutorial.zip压缩包。 $ unzip RabbitMQ-Tutorial.zip 进入RabbitMQ-Tutorial目录，该目录下包含预编译好的jar文件。 $ cd RabbitMQ-Tutorial 运行生产消息示例。 $ java -cp .:rabbitmq-tutorial.jar Send host port user password 其中，host表示RabbitMQ实例的连接地址，port为RabbitMQ实例的监听端口（默认为5672），user表示RabbitMQ用户名，password表示用户名对应的密码。图1 运行生产消息示例使用Ctrl+C命令退出。运行消费消息示例。 $ java -cp .:rabbitmq-tutorial.jar Recv host port user password 其中，host表示RabbitMQ实例的连接地址，port为RabbitMQ实例的监听端口（默认为5672），user表示RabbitMQ用户名，password表示用户名对应的密码。图2 运行消费消息示例如需停止消费使用Ctrl+C命令退出。

分布式消息服务RabbitMQ版步骤三：连接实例生产消费消息
分布式消息服务RabbitMQ版-不使用SSL证书连接:示例代码（Java）

示例代码（Java）连接实例并生产消息 ConnectionFactory factory = new ConnectionFactory(); factory.setHost(host); factory.setPort(port); factory.setUsername(user); factory.setPassword(password); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); channel.queueDeclare(QUEUE_NAME, false, false, false, null); String message = "Hello World!"; channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); System.out.println(" [x] Sent '" + message + "'"); channel.close(); connection.close(); 连接实例并消费消息 ConnectionFactory factory = new ConnectionFactory(); factory.setHost(host); factory.setPort(port); factory.setUsername(user); factory.setPassword(password); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); channel.queueDeclare(QUEUE_NAME, false, false, false, null); System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); 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, "UTF-8"); System.out.println(" [x] Received '" + message + "'"); } }; channel.basicConsume(QUEUE_NAME, true, consumer);

分布式消息服务RabbitMQ版步骤三：连接实例生产消费消息