0

我正在尝试使用命令行在rabbitmq-c 库（ssl-plumbing 分支）中运行 SSL 示例“amqps_listenq”

$./amqps_listenq [ServerIP]  5671 hello ./cacert.pem ./key.pem ./cert.pem

我收到以下错误

opening SSL/TLS connection

当我尝试调试代码时，它在 main 的以下块中失败

status = amqp_socket_open(socket, hostname, port);
if (status) {
    die("opening SSL/TLS connection");
}

当我调试“amqp_socket_open”方法时，我发现它在 amqp_openssl.c 的以下块中失败

if (self->verify) {
    int status = amqp_ssl_socket_verify(self, host);
    if (status) {
        return -1;
    }
}

我追踪了 amqp_ssl_socket_verify 里面的错误，发现我在下面的块中失败了

#ifdef _MSC_VER
#define strcasecmp _stricmp
#endif
    if (strcasecmp(host, (char *)utf8_value)) {
        goto error; //<-- it fails here
    }
#ifdef _MSC_VER
#undef strcasecmp
#endif
exit:
    OPENSSL_free(utf8_value);
    return status;
error:
    status = -1;
    goto exit;

状态等于-1 知道问题出在哪里吗？

请注意，即使我没有使用以下代码设置证书，我也可以使用 java 在同一服务器上使用 SSL 轻松连接到 RabbitMq

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("[ServerIP]");
factory.setPort(5671);
factory.useSslProtocol();
factory.setUsername("guest");
factory.setPassword("guest");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

channel.queueDeclare("hello_ssl", false, false, false, null);
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(QUEUE_NAME, true, consumer);

while (true){
  QueueingConsumer.Delivery delivery = consumer.nextDelivery();
  String message = new String(delivery.getBody());
  System.out.println(" [" + i + "] Received '" + message + "'");
}
4

2 回答 2

1

我一直在调试 librabbitmq，我看到了完全相同的行为。utf8_value 变量包含“amqp”，而主机变量包含 amqp 服务器主机名。

我有一个解决方法：

-  if (strcasecmp(host, (char *)utf8_value)) {
-    goto error;
+
+  if(strcasecmp((char *)utf8_value, "amqp")) {
+    if (strcasecmp(host, (char *)utf8_value) ) {
+      goto error;
+    }
   }

我在这里分叉和修补：https ://github.com/drainware/rabbitmq-c

于 2013-04-25T21:31:33.150 回答
0

问题出在证书上，验证证书详细信息中的域是否匹配。

于 2014-10-09T08:29:38.720 回答