zoukankan      html  css  js  c++  java
  • 用Spring cloud Stream来开发基于MQ消息驱动的微服务

    Spring boot对MQ类如RabbitMQ、kafka支持都很好,但是仍然要写一些模板代码。Spring cloud stream进一步掩盖了这个差异,仅仅使用配置就可以完成。

    Spring cloud Stream 用了基于topic-subsriber的模式,虽然不支持全部MQ的特性,但绝大多数应用来说,这样就足够用了,毕竟方便很多。具体用法如下:

    包含的包

            <dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-bus-amqp</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    		</dependency>

    MQ接口

    public interface MyMQInterface{
        @Input("通道名")
        SubscribableChannel inputChannel();
        @Output("通道名")
        MessageChannel outputChanel();
     }
    • 通道名发送方和接受方必须是一致的
    • 一个应用不能既是同一个通道的发送方和接收方,否则会警告。这实际上也没有意义。
    • 声明后,启用绑定
      @EnableBinding(MyMQInterface.class)
    • 可以绑定多个接口

    发送MQ消息

      @Autowired
      MyMQInterface myInterface;
      .....
      myInterface.inputChannel().send(MessageBuilder....);

    接受消息

    @SystemListener("通道名")
    public void onReceive(Message content)

    应用集群问题

    • 如果某个应用起来多个实例,如上面的配置,会导致每条消息每个实例都会收到,如果你不想这么做,请在配置里面加上:
    spring.cloud.stream.bindings.testOrders.group=分组名
    • 每个应用定义一个唯一的分组名,不好和其他应用重复。

    消息处理异常

    • 如果收到消息处理有问题,比如写入数据库失败,请抛出RuntimeException异常,MQ会重试,不过重试几次后会失败,这个要注意。
  • 相关阅读:
    刷皇室成员
    python 2.7中matplotlib的所有版本
    Linux命令使用时路径存在空格、特殊符号
    路径名太长导致无法读取文件
    谷歌浏览器打包插件
    Upload 上载新生
    Linux的终端(base),进入base环境
    Ubuntu16.04系统语言设置为中文以及搜狗输入法的安装
    R语言3D图导出矢量图有bug
    将本地文件复制到hadoop文件系统
  • 原文地址:https://www.cnblogs.com/bobdeng/p/6555086.html
Copyright © 2011-2022 走看看