如何通过代码将Socks 5代理与Sping Boot 集成以连接AMQP-RabbitMQ

f2uvfpb9  于 2022-11-23  发布在  RabbitMQ
关注(0)|答案(1)|浏览(260)

基本上我尝试使用SOCKS 5代理连接RabbitMq和Sping Boot 项目。
我已经创建了自定义套接字工厂并连接到PostgreSQL,在这种情况下,连接对象接受SocketFactory作为参数,如下所示;

Properties props = new Properties();
props.setProperty("user", "username");
props.setProperty("password", "password");
props.setProperty("socketFactory", DBSocketFactory.class.getName());
Connection conn = DriverManager.getConnection(url, props);
return conn;

请大家帮忙,我们怎样才能实现通过SOCKS 5代理连接Sping Boot 项目中的RabbitMq。
在项目中,我们使用非常标准的ConnectorFactory bean和RabbitTemplate注解方法,如下所示

@Bean(name = "default-rabbit-connection-factory")
    public ConnectionFactory defaultConnectionFactory() {

        RabbitConnectionDto defaultConnectionDto = rabbitConnectionProperty.getConnections().stream()
                .filter(con -> con.getName().equals("DEFAULT"))
                .findFirst()
                .orElse(null);

        if (defaultConnectionDto == null) {
            log.error("No default Rabbit Connection!!!");
            return null;
        }

        return getConnectionFactory(defaultConnectionDto);
    }

    @Bean(name = "defaultRabbitTemplate")
    public RabbitTemplate defaultRabbitTemplate() {
        return new RabbitTemplate(defaultConnectionFactory());
    }

谢谢你!

zte4gxcn

zte4gxcn1#

已解决
使用了RabbitConnectionFactoryBean类并将套接字工厂作为参数提供给该类
🌸

相关问题