Springcloud bus自定义消息不能通过rabbitmq发送

Question

当使用rabbitmq总线时，会创建一个自定义消息并通过sent发送，但消息发送后，它不会去springcloud。当您尝试call /actuator/bus-refresh时，您可以看到从rabbitmq的控制台页面发出的总线消息。

我尝试启动微服务来注册自定义事件监听器，但接收失败。但是，如果发送者自己注册了一个侦听器，他可以接收它，但不能从rabbitmq发送它。

 <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.3.RELEASE</version>
        <relativePath/>
    </parent>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Greenwich.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

关于@RemoteApplicationEventScan注释，我都在同一个包中编写代码，所以我应该能够扫描到TestEvent。我还尝试指定basepackage。

@SpringBootApplication
@RemoteApplicationEventScan
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

@RestController
@RequestMapping("test")
public class TestController {

    @Autowired
    private ApplicationContext context;

    @RequestMapping("test")
    public String test() {

        final TestEvent testEvent = new TestEvent(this, context.getId(), null,"test");
        context.publishEvent(testEvent);
        return "success";
    }
}

@Data
public class TestEvent extends RemoteApplicationEvent {

    private String action;


    public TestEvent(Object source, String originService, String destinationService, String action) {
        super(source, originService, destinationService);
        this.action = action;
    }
}

当我调用http://localhost:8080/actuator/bus-refresh时，我可以在rabbitmq中看到信息。

{" type ":" AckRemoteApplicationEvent ", "timestamp" : 1554350325406, "originService" : "application: 0: b3461fbec3536203a7020ff9d24bb11b", "destinationService" : "* *", "id" : "e6b875bd - 2402-494 - f - a870 - 4917324 d2c5c ackId ", "" :" af93075e - 55 d2-41 f8 - ba27 - e3c80cf19eea ", "ackDestinationService" : "* *", "the event" is: "org. Springframework. Cloud. Bus. Event. RefreshRemoteApplicationEvent"}. 

但是当我打电话给http://localhost:8080/test/test的时候，我不知道。

Answer 1

几天前我遇到了同样的问题，结果是因为originService不正确。以originService的形式传入context.getId()是不起作用的。

简而言之:使用org.springframework.cloud.bus.BusProperties#id。您可以将BusProperties注入到组件中。或者，您可以按照document中的说明配置您自己的spring cloud bus id。

我不是百分之百确定这是正确的方式。也许我在文档中漏掉了什么。它只是基于我从acceptLocal方法org.springframework.cloud.bus.BusAutoConfiguration的源代码中读到的内容。

希望它能为你工作。