如何通过代理/Web代理连接RabbitMQ服务器（Spring配置场景）

Hey there! Let's walk through how to set up your Spring Boot app to connect to RabbitMQ either through a traditional proxy (like SOCKS/HTTP) or a web proxy using AMQP over WebSocket, leveraging your existing credentials stored in application.yml.

1. Traditional Proxy (SOCKS/HTTP) Setup #

Spring Boot's default RabbitMQ auto-configuration doesn't include proxy support out of the box, but you can easily customize the ConnectionFactory to add proxy settings.

Step 1: Add Proxy Configuration to application.yml #

First, extend your existing RabbitMQ config with proxy details:

spring:
  rabbitmq:
    host: your-rabbitmq-host
    port: 5672
    username: your-username
    password: your-password
    # Custom proxy settings
    proxy:
      host: your-proxy-host
      port: 8080
      type: HTTP # Switch to SOCKS if using a SOCKS proxy
      # Optional: add if your proxy requires authentication
      username: proxy-username
      password: proxy-password

Step 2: Create a Custom ConnectionFactory Bean #

Create a configuration class to override the default connection factory and inject your proxy settings:

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.net.InetSocketAddress;
import java.net.Proxy;

@Configuration
public class RabbitMQProxyConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitHost;

    @Value("${spring.rabbitmq.port}")
    private int rabbitPort;

    @Value("${spring.rabbitmq.username}")
    private String rabbitUsername;

    @Value("${spring.rabbitmq.password}")
    private String rabbitPassword;

    @Value("${spring.rabbitmq.proxy.host}")
    private String proxyHost;

    @Value("${spring.rabbitmq.proxy.port}")
    private int proxyPort;

    @Value("${spring.rabbitmq.proxy.type}")
    private String proxyType;

    @Value("${spring.rabbitmq.proxy.username:#{null}}")
    private String proxyUsername;

    @Value("${spring.rabbitmq.proxy.password:#{null}}")
    private String proxyPassword;

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory factory = new CachingConnectionFactory(rabbitHost, rabbitPort);
        factory.setUsername(rabbitUsername);
        factory.setPassword(rabbitPassword);

        // Configure proxy type and address
        Proxy.Type type = "SOCKS".equalsIgnoreCase(proxyType) ? Proxy.Type.SOCKS : Proxy.Type.HTTP;
        Proxy proxy = new Proxy(type, new InetSocketAddress(proxyHost, proxyPort));
        factory.setProxy(proxy);

        // Add proxy authentication if credentials are provided
        if (proxyUsername != null && proxyPassword != null) {
            factory.setProxyAuth(proxyUsername, proxyPassword);
        }

        return factory;
    }
}

This bean will override Spring's default connection factory and route all RabbitMQ traffic through your specified proxy.

2. Web Proxy (AMQP over WebSocket) Setup #

If standard AMQP ports are blocked, you can use AMQP over WebSocket. First, ensure your RabbitMQ server has the web-stomp plugin enabled (run rabbitmq-plugins enable rabbitmq_web_stomp on the server).

Step 1: Update application.yml for WebSocket #

Modify your config to enable WebSocket support and add web proxy settings:

spring:
  rabbitmq:
    host: your-rabbitmq-host
    username: your-username
    password: your-password
    ws:
      enabled: true
      port: 15674 # Default RabbitMQ WebSocket port for web-stomp
      path: /ws # Default path, adjust if your server uses a different one
    # Web proxy settings
    proxy:
      host: your-web-proxy-host
      port: 8080

Step 2: Customize WebSocket Client with Proxy #

Create a config class to extend Spring's WebSocket connection factory and add proxy support:

import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.WebSocketConnectionFactory;
import org.springframework.amqp.rabbit.connection.WebSocketConnectionFactoryBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
import java.net.Proxy;
import java.net.InetSocketAddress;

@Configuration
public class RabbitMQWebSocketProxyConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitHost;

    @Value("${spring.rabbitmq.username}")
    private String rabbitUsername;

    @Value("${spring.rabbitmq.password}")
    private String rabbitPassword;

    @Value("${spring.rabbitmq.ws.port}")
    private int wsPort;

    @Value("${spring.rabbitmq.ws.path}")
    private String wsPath;

    @Value("${spring.rabbitmq.proxy.host}")
    private String proxyHost;

    @Value("${spring.rabbitmq.proxy.port}")
    private int proxyPort;

    @Bean
    public ConnectionFactory webSocketConnectionFactory() {
        // Configure WebSocket client with proxy
        StandardWebSocketClient webSocketClient = new StandardWebSocketClient();
        Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(proxyHost, proxyPort));
        webSocketClient.setProxy(proxy);

        // Build WebSocket connection factory
        return WebSocketConnectionFactoryBuilder
                .forHost(rabbitHost)
                .port(wsPort)
                .path(wsPath)
                .username(rabbitUsername)
                .password(rabbitPassword)
                .webSocketClient(webSocketClient)
                .build();
    }
}

Quick Notes: #

• Double-check that the rabbitmq_web_stomp plugin is active on your RabbitMQ server.
• If your web proxy requires authentication, you'll need to extend the StandardWebSocketClient with a custom HttpClient that handles proxy auth.

内容的提问来源于stack exchange，提问作者Yuton