基本上我尝试使用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());
}
谢谢你!
1条答案
按热度按时间zte4gxcn1#
已解决
使用了RabbitConnectionFactoryBean类并将套接字工厂作为参数提供给该类
🌸