建立套接字连接时出错

问题描述

我正在尝试运行下面的程序，但出现此错误:

I am trying to run the program below, but I am getting this error:

Exception in thread "main" java.net.ConnectException: Connection refused: connect
    at java.net.PlainSocketImpl.socketConnect(Native Method)
    at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351)
    at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
    at java.net.Socket.connect(Socket.java:529)
    at com.rabbitmq.client.ConnectionFactory.createFrameHandler(ConnectionFactory.java:445)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:504)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)
    at Recieve.main(Recieve.java:14)

我试图运行的程序是:

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Send {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws java.io.IOException {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        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());
        System.out.println(" [x] Sent '" + message + "'");
        channel.close();
        connection.close();
    }
}

我不知道建立套接字连接，请告诉我如何解决这个问题.

I am not aware of making a socket connection, please let me know how to resolve this.

推荐答案

以下是使代码正常工作应遵循的步骤:

Here are the steps you should follow for your code to work:

1. 下载并安装最新的 Erlang.
2. 下载 RabbitMQ 服务器.
3. 安装RabbitMQ服务器
4. 编译并运行您的代码，现在应该可以运行了.

希望这会有所帮助.

这篇关于建立套接字连接时出错的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！