[Stream发送] SpringCloudStream消息驱动的消息发送者配置

一时失言乱红尘 2021-12-23 14:47 272阅读 0赞

**搭配使用**  
logback日志配置:  
[https://blog.csdn.net/a755199443/article/details/92208902][https_blog.csdn.net_a755199443_article_details_92208902]

Eureka单机服务端配置:  
[https://blog.csdn.net/a755199443/article/details/92579936][https_blog.csdn.net_a755199443_article_details_92579936]

Eureka服务端集群配置:  
[https://blog.csdn.net/a755199443/article/details/92620273][https_blog.csdn.net_a755199443_article_details_92620273]

linux部署Eureka的服务端集群:  
[https://blog.csdn.net/a755199443/article/details/92637977][https_blog.csdn.net_a755199443_article_details_92637977]

消息驱动的消息接收者配置:  
[https://blog.csdn.net/a755199443/article/details/93717596][https_blog.csdn.net_a755199443_article_details_93717596]

消息分组配置:  
[https://blog.csdn.net/a755199443/article/details/93743806][https_blog.csdn.net_a755199443_article_details_93743806]

### SpringCloudStream消息驱动的消息发送者配置 ###

pom文件配置

全局配置文件

消息发送接口

启动类

测试类

### pom文件配置 ###

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
            <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.13.RELEASE</version>
            <relativePath />
        </parent>
    
        <groupId>com.zzw</groupId>
        <artifactId>stream_sender</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR5</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

### 全局配置文件 ###

文件名:application.properties

spring.application.name=stream_sender
    server.port=9050
    
    #设置服务注册中心地址，指向另一个注册中心
    eureka.client.serviceUrl.defaultZone=http://user:123456@eureka1:8761/eureka/,http://user:123456@eureka2:8761/eureka/
    
    #rebbitmq 链接信息
    spring.rabbitmq.host=192.168.110.129
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=admin
    spring.rabbitmq.password=123456
    spring.rabbitmq.virtualHost=/

### 消息发送接口 ###

**和启动类在同一级目录下**

文件名:ISendeService.java  
@Output注解的值应与消息接收者@Input注解中的值一致

public interface ISendeService { 
    
    	@Output("csdn-exchange")
    	SubscribableChannel send();
    }

### 启动类 ###

文件名:StreamSenderApplication.properties

**注意要加上@EnableBinding(value=\{ISendeService.class\}) 注解和消息发送接口做绑定**

@SpringBootApplication
    @EnableEurekaClient
    @EnableBinding(value={ ISendeService.class})
    public class StreamSenderApplication { 
    	public static void main(String[] args) { 
    		SpringApplication.run(StreamSenderApplication.class, args);
    	}
    }

### 测试类 ###

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;
    
    
    
    @SpringBootApplication
    @EnableEurekaClient
    @EnableBinding(value={ ISendeService.class})
    public class StreamSenderApplication { 
    	public static void main(String[] args) { 
    		SpringApplication.run(StreamSenderApplication.class, args);
    	}
    }

结果:  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NTUxOTk0NDM_size_16_color_FFFFFF_t_70]

[https_blog.csdn.net_a755199443_article_details_92208902]: https://blog.csdn.net/a755199443/article/details/92208902
[https_blog.csdn.net_a755199443_article_details_92579936]: https://blog.csdn.net/a755199443/article/details/92579936
[https_blog.csdn.net_a755199443_article_details_92620273]: https://blog.csdn.net/a755199443/article/details/92620273
[https_blog.csdn.net_a755199443_article_details_92637977]: https://blog.csdn.net/a755199443/article/details/92637977
[https_blog.csdn.net_a755199443_article_details_93717596]: https://blog.csdn.net/a755199443/article/details/93717596
[https_blog.csdn.net_a755199443_article_details_93743806]: https://blog.csdn.net/a755199443/article/details/93743806
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NTUxOTk0NDM_size_16_color_FFFFFF_t_70]: /images/20211223/1983458866e64e348a6e6d2813f32161.png