小编Mig*_*uel的帖子

在localhost中Ansible SSH ERROR连接

当我针对localhost主机启动我的playbook时出现此错误.

TASK [setup] *******************************************************************
fatal: [127.0.0.1]: UNREACHABLE! => {"changed": false, "msg": "SSH encountered an unknown error during the connection. We recommend you re-run the command using -vvvv, which will enable SSH debugging output to help diagnose the issue", "unreachable": true}
to retry, use: --limit @deploy-test-env.retry

PLAY RECAP *********************************************************************
127.0.0.1                  : ok=0    changed=0    unreachable=1    failed=0
Run Code Online (Sandbox Code Playgroud)

我的hosts文件有这个配置:

[local]
127.0.0.1
Run Code Online (Sandbox Code Playgroud)

问题是什么?

谢谢!

ssh ansible ansible-playbook

27
推荐指数
1
解决办法
2万
查看次数

我需要在我的单元Test中模拟一个RabbitMQ

我在我的项目中使用RabbitMQ.

我在我的消费者中有rabbitMQ的客户端部分的代码,并且连接需要tls1.1来连接真实的MQ.

我想在我的JUnit测试中测试这段代码,并模拟向我的消费者传递的消息.

我在google中看到几个不同工具的例子,如骆驼兔或activeMQ,但这个工具适用于amqp 1.0,而rabbitMQ只适用于amqp 0.9.

有人有这个问题吗?

谢谢!

UPDATE

这是测试从队列接收json的代码.

package com.foo.foo.queue;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.URL;
import java.security.*;
import java.security.cert.CertificateException;
import javax.net.ssl.*;

import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.json.JSONObject;

import com.foo.foo.Constants.Constants;
import com.foo.foo.core.ConfigurationContainer;
import com.foo.foo.policyfinders.PolicyFinder;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;

public class BrokerThreadHLConsumer extends Thread {

private static BrokerThreadHLConsumer instance;

private static final Logger log = LogManager.getLogger(BrokerThreadHLConsumer.class);

private Channel channel;
private String queueName;
private PolicyFinder PolicyFinder;
private Connection connection;
private QueueingConsumer consumer; …
Run Code Online (Sandbox Code Playgroud)

java junit mocking amqp rabbitmq

8
推荐指数
2
解决办法
8605
查看次数

RabbitMQ 中 ssl 连接的握手超时错误

我正在遵循带有 ssl 连接的 RabbitMQ教程

我已经为 ssl 连接配置了 5672 端口,并且正在启动 openssl 工具

用于测试本地端口的连接(是RabbitMQ的官方docker容器)。

我的rabbitmq.config是:

[{rabbit,   [ {loopback_users, []},
       {tcp_listeners, [5671]},
       {ssl_listeners, [5672]},
       {auth_mechanisms, ['EXTERNAL','PLAIN']},
       {handshake_timeout, 60000},
       {ssl_options, [
         {cacertfile, "/etc/rabbitmq/ssl/ca/cacert.pem" },
         {certfile, "/etc/rabbitmq/ssl/server/server.cert.pem" },
         {keyfile, "/etc/rabbitmq/ssl/server/server.key.pem" },
         {verify, verify_peer},
         {ssl_cert_login_from, common_name},
         {fail_if_no_peer_cert, true }]}]}].
Run Code Online (Sandbox Code Playgroud)

然后我执行这个命令:

openssl s_client -connect localhost:5672 -cert ../client/client.pem -key ../client/client.key.pem -CAfile ../ca/cacert.pem
Run Code Online (Sandbox Code Playgroud)

我在 RabbitMQ 日志中收到此错误:

=INFO REPORT==== 6-Apr-2016::14:16:06 ===
accepting AMQP connection <0.696.0> (127.0.0.1:34977 -> 127.0.0.1:5672)

=ERROR REPORT==== 6-Apr-2016::14:16:06 ===
closing AMQP connection <0.696.0> (127.0.0.1:34977 -> …
Run Code Online (Sandbox Code Playgroud)

ssl openssl rabbitmq

4
推荐指数
1
解决办法
7903
查看次数

标签 统计

rabbitmq ×2

amqp ×1

ansible ×1

ansible-playbook ×1

java ×1

junit ×1

mocking ×1

openssl ×1

ssh ×1

ssl ×1