Spring Integration 实现消息驱动的详细步骤

<dependencies>
    <!-- Spring Integration Core -->
    <dependency>
        <groupId>org.springframework.integration</groupId>
        <artifactId>spring-integration-core</artifactId>
        <version>5.5.10</version> <!-- 使用最新版本 -->
    </dependency>
    <!-- Spring Integration with AMQP (如果需要) -->
    <dependency>
        <groupId>org.springframework.integration</groupId>
        <artifactId>spring-integration-amqp</artifactId>
        <version>5.5.10</version> <!-- 使用最新版本 -->
    </dependency>
    <!-- 其他相关依赖 -->
</dependencies>

<!-- Spring Integration Config -->
<bean id="inputChannel" class="org.springframework.integration.core.MessagingTemplate" />
<channel id="inputChannel" />
<bean id="outputChannel" class="org.springframework.integration.core.MessagingTemplate" />
<channel id="outputChannel" />
<service-activator id="messageHandler" input-channel="inputChannel" output-channel="outputChannel" ref="yourMessageHandler" method="handleMessage" />

@Component
public class YourMessageHandler {
    public void handleMessage(Message<?> message) {
        // 处理消息
        Object payload = message.getPayload();
        // ... 业务逻辑处理
    }
}

// 发送消息
public void sendMessage(String message) {
    MessagingTemplate messagingTemplate = new MessagingTemplate();
    messagingTemplate.convertAndSend("inputChannel", message);
}
// 接收消息
public void receiveMessage() {
    // 消息将通过配置的messageHandler进行处理
}

<!-- Queue Channel -->
<bean id="queueChannel" class="org.springframework.integration.channel.QueueChannel" />
<channel id="queueChannel" ref="queueChannel" />
<!-- Topic Channel -->
<bean id="topicChannel" class="org.springframework.integration.ip.tcp.TcpNetServer" destroy-method="stop">
    <property name="port" value="1234" />
    <property name="serverListenerContainerFactory" ref="serverListenerContainerFactory" />
</bean>

<!-- RabbitMQ Config -->
<rabbit:connection-factory id="connectionFactory" host="localhost" port="5672" username="guest" password="guest" />
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" />
<rabbit:admin connection-factory="connectionFactory" />
<!-- ActiveMQ Config -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>

@SpringBootApplication
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}