Socks5代理如何与SpringBoot集成，通过代码连接AMQP-RabbitMQ

Question

基本上，我正在尝试使用SOCKS5代理将RabbitMq与Spring Boot项目连接起来。

我已经创建了Custom Socket工厂并连接到PostgreDB，在这种情况下，连接对象接受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;

请任何人帮忙，我们如何通过SOCKS5代理在Spring 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());
}

谢谢！

Answer 1

已解决

使用RabbitConnectionFactoryBean类，并将套接字工厂作为参数

🌸