<span style="font-size: 16px;"><!-- 引入MQ消息驱动的微服务包，引入stream只需要进行配置化即可，是对rabbit、kafka很好的封装 -->
<dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency></span>  复制代码

<span style="font-size: 16px;">server:  port: 5666
spring:  application:  name: commonservice-mq-producer  profiles:   active: dev  cloud:  config:  discovery:   enabled: true  service-id: commonservice-config-server  <span style="color: #ff0000;"># rabbitmq和kafka都有相关配置的默认值，如果修改，可以再次进行配置  stream:  bindings:  mqScoreOutput:   destination: honghu_exchange  contentType: application/json  rabbitmq:  host: localhost  port: 5672  username: honghu  password: honghu</span>
eureka:   client:  service-url:  defaultZone: http://honghu:123456@localhost:8761/eureka  instance:  prefer-ip-address: true</span>  复制代码

<span style="font-size: 16px;">package com.honghu.cloud.producer;  import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.SubscribableChannel;  public interface ProducerService {  String SCORE_OUPUT = "mqScoreOutput";  @Output(ProducerService.SCORE_OUPUT)  SubscribableChannel sendMessage();
}</span>  复制代码

<span style="font-size: 16px;">package com.honghu.cloud.producer;  import org.springframework.cloud.stream.annotation.EnableBinding;  @EnableBinding(ProducerService.class)
public class SendServerConfig {  }</span>  复制代码

<span style="font-size: 16px;">package com.honghu.cloud.controller;  import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.Message;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;  import com.honghu.cloud.common.code.ResponseCode;
import com.honghu.cloud.common.code.ResponseVO;
import com.honghu.cloud.entity.User;
import com.honghu.cloud.producer.ProducerService;  import net.sf.json.JSONObject;  @RestController
@RequestMapping(value = "producer")
public class ProducerController {  @Autowired  private ProducerService producerService;  /** * 通过get方式发送</span>对象<span style="font-size: 16px;"> * @param name 路径参数 * @return 成功|失败 */  @RequestMapping(value = "/sendObj", method = RequestMethod.GET)  public ResponseVO sendObj() {  User user = new User(1, "hello User");  <span style="color: #ff0000;">Message<User> msg = MessageBuilder.withPayload(user).build();</span>  boolean result = producerService.sendMessage().send(msg);  if(result){  return ResponseCode.buildEnumResponseVO(ResponseCode.RESPONSE_CODE_SUCCESS, false);  }  return ResponseCode.buildEnumResponseVO(ResponseCode.RESPONSE_CODE_FAILURE, false);  }  /** * 通过get方式发送字符串消息 * @param name 路径参数 * @return 成功|失败 */  @RequestMapping(value = "/send/{name}", method = RequestMethod.GET)  public ResponseVO send(@PathVariable(value = "name", required = true) String name) {  Message msg = MessageBuilder.withPayload(name.getBytes()).build();  boolean result = producerService.sendMessage().send(msg);  if(result){  return ResponseCode.buildEnumResponseVO(ResponseCode.RESPONSE_CODE_SUCCESS, false);  }  return ResponseCode.buildEnumResponseVO(ResponseCode.RESPONSE_CODE_FAILURE, false);  }  /** * 通过post方式发送</span>json对象<span style="font-size: 16px;"> * @param name 路径参数 * @return 成功|失败 */  @RequestMapping(value = "/sendJsonObj", method = RequestMethod.POST)  public ResponseVO sendJsonObj(@RequestBody JSONObject jsonObj) {  Message<JSONObject> msg = MessageBuilder.withPayload(jsonObj).build();  boolean result = producerService.sendMessage().send(msg);  if(result){  return ResponseCode.buildEnumResponseVO(ResponseCode.RESPONSE_CODE_SUCCESS, false);  }  return ResponseCode.buildEnumResponseVO(ResponseCode.RESPONSE_CODE_FAILURE, false);  }
}
</span>  复制代码

<!-- 引入MQ消息驱动的微服务包，引入stream只需要进行配置化即可，是对rabbit、kafka很好的封装 -->
<dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>  复制代码

server:  port: 5111
spring:  application:  name: commonservice-mq-consumer1  profiles:   active: dev  cloud:  config:  discovery:   enabled: true  service-id: commonservice-config-server  <span style="color: #ff0000;">stream:  bindings:  mqScoreInput:  group: honghu_queue  destination: honghu_exchange  contentType: application/json  rabbitmq:  host: localhost  port: 5672  username: honghu  password: honghu</span>
eureka:   client:  service-url:  defaultZone: http://honghu:123456@localhost:8761/eureka  instance:  prefer-ip-address: true  复制代码

package com.honghu.cloud.consumer;  import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;  public interface ConsumerService {  <span style="color: #ff0000;">String SCORE_INPUT = "mqScoreInput";  @Input(ConsumerService.SCORE_INPUT)  SubscribableChannel sendMessage();</span>  }  复制代码

package com.honghu.cloud;  import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;  import com.honghu.cloud.consumer.ConsumerService;
import com.honghu.cloud.entity.User;  @EnableEurekaClient
@SpringBootApplication
@EnableBinding(ConsumerService.class) //可以绑定多个接口
public class ConsumerApplication {  public static void main(String[] args) {  SpringApplication.run(ConsumerApplication.class, args);  }  <span style="color: #ff0000;">@StreamListener(ConsumerService.SCORE_INPUT)  public void onMessage(Object obj) {  System.out.println("消费者1，接收到的消息：" + obj);  }</span>  }  复制代码