22.Spring Cloud整合RabbitMQ或Kafka消息驱动

package com.init.springCloud; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.integration.support.MessageBuilder; import org.springframework.messaging.Message; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; @RestController public class ProviderController { @Autowired private SendMessageService sendMessageService; @RequestMapping(value = "/send", method = RequestMethod.GET) @ResponseBody public String sendMessage(){ Message<byte[]> message = MessageBuilder.withPayload("Hello World".getBytes()).build(); sendMessageService.myOutput().send(message); return "success"; } }