Как прокси-сервер Socks5 можно интегрировать с Spring Boot для подключения AMQP — RabbitMQ через код

Question

В основном я пытаюсь использовать прокси-сервер SOCKS5 для подключения RabbitMq к проекту Spring Boot.

Я создал Custom Socket factory и подключился к 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;

Может кто-нибудь, пожалуйста, помогите, как мы можем подключить RabbitMq в проекте Spring Boot через прокси-сервер SOCKS5.

В проекте мы используем довольно стандартные bean-компоненты ConnectorFactory и аннотированные методы 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 и дал фабрику сокетов в качестве параметра