多租戶電子商城系統(tǒng)Springcloud Bus原理總結(jié)

1.spring cloud bus

Sprcloud是根據(jù)spring的配置集成了一系列微服務(wù)框架。Sprcloud總線是微服務(wù)框架之一，用于實(shí)現(xiàn)微服務(wù)之間的通信。

JAVA分布式微服務(wù)云構(gòu)建B2B2C電子商務(wù)平臺(tái)源碼 Spring Cloud大型企業(yè)

Sprcloud總線集成了java的事件處理機(jī)制和消息中間件消息收發(fā)，主要由sender、receiver和event組成。針對(duì)不同的業(yè)務(wù)需求，可以設(shè)置不同的事件，發(fā)送方發(fā)送事件，接收方接收相應(yīng)的事件并進(jìn)行相應(yīng)的處理。

2.spring cloud bus實(shí)戰(zhàn)

網(wǎng)上有很多關(guān)于spring cloud bus的demo，這里就不贅述了。

3.原理

Spring cloud bus 集成了java事件處理機(jī)制和消息中間件，所以下面兩個(gè)方面來說明spring cloud bus的原理。

如圖，給出如下解釋：

(1)完整的過程：發(fā)送者(端點(diǎn))構(gòu)建體事件，發(fā)布ES它上下文的上下文(彈簧云總線具有父上下文，自舉)，則將該事件發(fā)送至信道(JSON串消息)，則接收機(jī)獲取消息從信道，轉(zhuǎn)換的消息到事件(轉(zhuǎn)換過程沒有深入研究)，然后公布事件事件事件。ish到context context，最后Listener接收到事件并調(diào)用service進(jìn)行處理。在整個(gè)過程中，只有發(fā)送/接收端從上下文上下文上下文中獲取事件和發(fā)送事件，需要在代碼中寫清楚. 其他部分由框架封裝。

(2) 首先，我們概括地描述該過程。關(guān)于封裝的一些過程，我們基本可以在BusAutoConfiguration.class中找到。下面的代碼在這個(gè)類中。

　　@EventListener(classes = RemoteApplicationEvent.class)
    public void acceptLocal(RemoteApplicationEvent event) {
        if (this.serviceMatcher.isFromSelf(event)
                && !(event instanceof AckRemoteApplicationEvent)) {
            this.cloudBusOutboundChannel.send(MessageBuilder.withPayload(event).build());
        }
    }

這封裝了java事件處理機(jī)制。當(dāng)接收到 RemoteApplication Event 時(shí)，如果該事件是從服務(wù)發(fā)送的，并且不是 ack 事件，則將該事件發(fā)送到通道。

　　@StreamListener(SpringCloudBusClient.INPUT)
    public void acceptRemote(RemoteApplicationEvent event) {
        if (event instanceof AckRemoteApplicationEvent) {
            if (this.bus.getTrace().isEnabled() && !this.serviceMatcher.isFromSelf(event)
                    && this.applicationEventPublisher != null) {
                this.applicationEventPublisher.publishEvent(event);
            }
            // If it's an ACK we are finished processing at this point
            return;
        }
        if (this.serviceMatcher.isForSelf(event)
                && this.applicationEventPublisher != null) {
            if (!this.serviceMatcher.isFromSelf(event)) {
                this.applicationEventPublisher.publishEvent(event);
            }
            if (this.bus.getAck().isEnabled()) {
                AckRemoteApplicationEvent ack = new AckRemoteApplicationEvent(this,
                        this.serviceMatcher.getServiceId(),
                        this.bus.getAck().getDestinationService(),
                        event.getDestinationService(), event.getId(), event.getClass());
                this.cloudBusOutboundChannel
                        .send(MessageBuilder.withPayload(ack).build());
                this.applicationEventPublisher.publishEvent(ack);
            }
        }
        if (this.bus.getTrace().isEnabled() && this.applicationEventPublisher != null) {
            // We are set to register sent events so publish it for local consumption,
            // irrespective of the origin
            this.applicationEventPublisher.publishEvent(new SentApplicationEvent(this,
                    event.getOriginService(), event.getDestinationService(),
                    event.getId(), event.getClass()));
        }
    }

StreamListener 是一個(gè)有趣的標(biāo)簽，您可以查看。這個(gè)方法是從channel中提取事件處理的過程(message to event部分需要自己理解，我沒有深入研究過)，根據(jù)事件的類型，發(fā)送方和接收方來處理這個(gè)事件：如果是一個(gè)ack 事件，將其發(fā)送到上下文上下文;如果它是接收者而不是發(fā)送者，它會(huì)將事件發(fā)送到上下文上下文。

(3)消息中間件可以采用rabbitmq、kafka等。

以上就是關(guān)于“多租戶電子商城系統(tǒng)SpringCloud原理總結(jié)”的介紹，如果大家對(duì)此感興趣，不妨來關(guān)注一下動(dòng)力節(jié)點(diǎn)的SpringCloud教程，相信對(duì)大家的學(xué)習(xí)會(huì)有一定的幫助。