Spring Boot嵌入式ActiveMQ：如何用Java配置动态添加多个NetworkConnectors

Got it, I’ve dealt with this exact requirement before—adding NetworkConnectors to an embedded ActiveMQ broker at runtime without relying on the traditional activemq.xml config. Here’s a straightforward Java-based solution using Spring Boot:

Step 1: Inject the BrokerService #

Spring Boot automatically creates and manages the BrokerService instance for embedded ActiveMQ. You can inject this directly into a component to manipulate the broker:

import org.apache.activemq.broker.BrokerService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class ActiveMQNetworkManager {

    private final BrokerService brokerService;

    @Autowired
    public ActiveMQNetworkManager(BrokerService brokerService) {
        this.brokerService = brokerService;
    }
}

Step 2: Add a Method to Dynamically Add NetworkConnectors #

Add a method to handle adding new connectors, including checks to avoid duplicates and starting the connector if the broker is already running:

// Inside ActiveMQNetworkManager
public void addNetworkConnector(String connectorUri) throws Exception {
    // Check if the connector already exists to prevent duplicates
    boolean connectorExists = brokerService.getNetworkConnectors().stream()
            .anyMatch(connector -> connector.getUri().equalsIgnoreCase(connectorUri));

    if (!connectorExists) {
        // Add the new network connector
        brokerService.addNetworkConnector(connectorUri);

        // If the broker is already running, start the new connector immediately
        if (brokerService.isStarted()) {
            brokerService.getNetworkConnectorByName(connectorUri).start();
        }
    }
}

Step 3: Use the Manager in Your Application #

You can call this method from anywhere in your app—like a REST controller, service, or event listener. For example, a REST endpoint to trigger adding connectors:

import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/activemq/network")
public class MQNetworkController {

    private final ActiveMQNetworkManager networkManager;

    public MQNetworkController(ActiveMQNetworkManager networkManager) {
        this.networkManager = networkManager;
    }

    @PostMapping("/add")
    public ResponseEntity<String> addConnector(@RequestParam String uri) {
        try {
            networkManager.addNetworkConnector(uri);
            return ResponseEntity.ok(String.format("Network connector '%s' added successfully", uri));
        } catch (Exception e) {
            return ResponseEntity.status(500)
                    .body(String.format("Failed to add connector: %s", e.getMessage()));
        }
    }
}

Key Notes #

• Broker State Handling: If the broker hasn’t started yet (e.g., during app initialization), the added connectors will start automatically when the broker launches. If it’s already running, we explicitly call start() on the new connector.
• Base Broker Configuration: You can set up basic embedded broker settings via application.properties or application.yml instead of XML:

  spring.activemq.in-memory=true
  spring.activemq.broker-url=vm://localhost?broker.persistent=false
  

• Removing Connectors: To remove a connector later, use brokerService.removeNetworkConnector(connector)—you can fetch the connector by URI or name first.

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