“你好世界”不适用于rabbitmq

wmtdaxz3 于 2022-11-23 发布在 RabbitMQ

关注(0)|答案(3)|浏览(133)

我是rabbitmq的新手，但是由于某些（未知的）原因，“hello world”程序对我不起作用。send.py和receive.py只是从教程页面复制粘贴而来：
http://www.rabbitmq.com/tutorials/tutorial-one-python.html
rabbitmq是使用“yum”安装在RHEL 6上的。Python版本是2.6。

$ service rabbitmq-server start

并输出“SUCCESS”。
运行www.example.com和www.example.com不会出现错误或警告消息send.pyreceive.py:

$ python send.py
 [x] Sent 'Hello World!'

$ python receive.py
 [*] Waiting for messages. To exit press CTRL+C

那么它永远不会打印“Hello World！"。
有什么问题吗？

rabbitmq

来源：https://stackoverflow.com/questions/10588071/hello-world-not-work-for-rabbitmq

3条答案

按热度按时间

7rfyedvj1#

首先启用管理控制台

sudo rabbitmq-plugins enable rabbitmq_management

然后打开浏览器

http://localhost:55672

登录方式：guest/guest
在我的例子中，它是内存（低于2千兆）和消息"该节点的磁盘可用空间警报已经关闭。它将阻止传入的网络流量，直到可用空间量超过限制。"
编辑文件/etc/rabbitmq/rabbitmq.config，如下所示：

[
    {rabbit, [{disk_free_limit, {mem_relative, 0.1}}]}
 ]

现在重新启动Rabbit服务：

service rabbitmq-server stop
service rabbitmq-server start

赞(0）回复(0）举报 2022-11-23

kuarbcqp2#

必须启动Rabbit MQ Serever。在windows文件名中：RabbitMQ Service - start。可以使用以下代码：

import java.io.IOException;
import java.util.ResourceBundle;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class NewTaskController implements Runnable {
    private final String message;

     private static final String EXCHANGE_NAME = "test";

     private static final String ROUTING_KEY = "test";

     public NewTaskController(final String message) {
         this.message = message;
     }

     @Override
     public void run() {

        //getting data from application.properties
         //for the rabbit_mq configuration

         ResourceBundle mRB = ResourceBundle.getBundle("application");

         System.out.println("*****NewTaskController************"+mRB.getString("rabbitmq.port"));
        String rabbitmq_username = mRB.getString("rabbitmq.username");
        String rabbitmq_password = mRB.getString("rabbitmq.password");
                String rabbitmq_hostname = mRB.getString("rabbitmq.hostname");
                        int rabbitmq_port = Integer.parseInt(mRB.getString("rabbitmq.port"));
     ConnectionFactory factory = new ConnectionFactory();
     factory.setUsername(rabbitmq_username);
     factory.setPassword(rabbitmq_password);
     factory.setHost(rabbitmq_hostname);
     factory.setPort(rabbitmq_port);
     Connection conn;
     try {
     conn = factory.newConnection();
     Channel channel = conn.createChannel();

     channel.exchangeDeclare(EXCHANGE_NAME, "direct", true);
     String queueName = channel.queueDeclare().getQueue();
     System.out.println(queueName);
     channel.queueBind(queueName, EXCHANGE_NAME, ROUTING_KEY);
     System.out.println("Producing message: " + message + " in thread: " + Thread.currentThread().getName());
     channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes());

     try {
        channel.close();
    } catch (TimeoutException e) {
        e.printStackTrace();
    }
     conn.close();
     } catch (IOException | TimeoutException e) {
     e.printStackTrace();
     }
}
}

application.properties file

rabbitmq.username=guest
rabbitmq.password=guest
rabbitmq.hostname=localhost
rabbitmq.port=5672

赞(0）回复(0）举报 2022-11-23

xmq68pz93#

我在使用C# dotnet的Windows操作系统上遇到过同样的问题。
我通过改变项目目录解决了这个问题。它位于D驱动器上。
我把它移到C盘了，就这样了！

赞(0）回复(0）举报 2022-11-23