springcloud 实战总结架构图和集成rabbitMQ（二十一）

r囧r小猫 2022-12-14 13:40 90阅读 0赞

springcloud 实战总结架构图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70][]

springcloud对应的springboot版本大概图示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2][]

springboot 配置：

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.5.RELEASE</version>
    </parent>

springcloud 配置，里面包含springcloud的各种插件配置，唯独不包含springboot 相关信息，所以需要但的引入：

<dependencyManagement>
        <dependencies>
            <dependency>
              <groupId>org.springframework.cloud</groupId>
              <artifactId>spring-cloud-dependencies</artifactId>
              <version>Hoxton.SR3</version>
              <type>pom</type>
              <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

集成RabbitMQ ,pom.xml文件配置：

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

一、客户端8001代码

1、bootstrap.xml配置：

spring:
      cloud:
        config:
          name: mq
          discovery:
            enabled: true
            service-id: config
          profile: dev
        stream:
          bindings:
            outputEnjoyMsg:    //配置
              destination: ame  //消息通道
      application:
        name: client_a
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:6789/eureka/

2、service层

import org.springframework.cloud.stream.annotation.Output;
    import org.springframework.messaging.MessageChannel;
    import org.springframework.stereotype.Component;
    
    @Component
    public interface OutBindingClient {
        @Output("outputEnjoyMsg")
        MessageChannel output();
    }

3、controller层：

import com.shadow.message.OutBindingClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.messaging.support.MessageBuilder;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class MQController {
        @Autowired
        OutBindingClient outBindingClient;
        @GetMapping("/sendMsg")
        public void sendMsg(){
            outBindingClient.output().send(MessageBuilder.withPayload("nandao好帅").build());
        }
    }

二、接收端8002代码：

1、通道接收代码：

import org.springframework.cloud.stream.annotation.Input;
    import org.springframework.messaging.SubscribableChannel;
    import org.springframework.stereotype.Component;
    
    @Component
    public interface InputMsgBinding {
        @Input("inputMsg")
        SubscribableChannel input();
    }

2、监听代码：

import org.springframework.cloud.stream.annotation.EnableBinding;
    import org.springframework.cloud.stream.annotation.StreamListener;
    import org.springframework.stereotype.Component;
    
    @Component
    @EnableBinding(InputMsgBinding.class)
    public class ReceverMessage {
        @StreamListener("inputMsg")
        public void post(Object msg){
            System.out.println("msg==========="+msg);
        }
    }

3、xml配置：

spring:
      cloud:
        config:
          name: mq
          discovery:
            enabled: true
            service-id: config
          profile: dev
        stream:
          bindings:
            inputMsg:
              destination: ame
      application:
        name: client_b
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:6789/eureka/

这样就集成了springcloud版的rabbitMQ

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70]: /images/20221123/7976ffb658be4e53b65ac8b102a488c8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1]: /images/20221123/1ab7583502d94cb78df85e7f6bf3ba28.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2]: /images/20221123/6ed3353a31c04d38af51bdbcb6c980a7.png