SpringBoot-分布式整合

分布式

目錄

• 分布式
  • 1. Dubbo
  • 2. 整合Dubbo Zookeeper SpringBoot
    • 1. 提供者提供服務
      • 1. 導入依賴
      • 2. 配置文件
      • 3. 注冊服務
    • 2. 消費者如何消費
      • 1. 導入依賴
      • 2. 配置文件
      • 3. 從遠程注入服務
    • 3. 注意

1. Dubbo

2. 整合Dubbo Zookeeper SpringBoot

1. 提供者提供服務

1. 導入依賴

<!--導入依賴 dubbo + zookeeper-->
<!--dubbo-->
<!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter -->
<dependency>
   <groupId>org.apache.dubbo</groupId>
   <artifactId>dubbo-spring-boot-starter</artifactId>
   <version>2.7.8</version>
</dependency>
<!--引入zookeeper-->
<!--zookeeper client-->
<!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
<dependency>
   <groupId>com.github.sgroschupf</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.1</version>
</dependency>
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-framework</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-recipes</artifactId>
   <version>2.12.0</version>
</dependency>
<dependency>
   <groupId>org.apache.zookeeper</groupId>
   <artifactId>zookeeper</artifactId>
   <version>3.6.2</version>
   <!--由於日志會沖突, 排出這個slf4j-log4j12-->
   <exclusions>
      <exclusion>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-log4j12</artifactId>
      </exclusion>
   </exclusions>
</dependency>

2. 配置文件

配置注冊中心的地址, 以及服務發現名, 和要掃描的包

server.port=8001

# 服務應用名字
dubbo.application.name=provider-server
# 注冊中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
# 哪些服務要被注冊
dubbo.scan.base-packages=com.wang.service

3. 注冊服務

接口

package com.wang.service;

public interface TicketService {
    String getTicket();
}

實現類

package com.wang.service;

import com.alibaba.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

//zookeeper: 服務注冊與發現

//使用了dubbo后, 盡量不要使用Service注解(SpringBoot的Service)
//這里的Service注解是dubbo的, 不要導錯包!
@Service
//可以被掃描到, 在項目啟動就自動注冊到注冊中心
@Component
public class TicketServiceImpl implements TicketService {
    @Override
    public String getTicket() {
        return "得到一張票!";
    }
}

2. 消費者如何消費

1. 導入依賴

與上面相同

2. 配置文件

配置注冊中心的地址, 配置自己的服務名

server.port=8002

# 消費者去哪里拿服務, 要暴露自己的名字
dubbo.application.name=consumer-server
# 注冊中心的地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

3. 從遠程注入服務

package com.wang.service;

import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

//放到容器中, 這里要用SpringBoot的
@Service
public class UserService {
    //想拿到provider-server提供的票, 要去注冊中心拿到服務
    //引用, Pom坐標, 也可以定義與要使用的接口路徑相同的接口名
    @Reference
    TicketService TICKET_SERVICE;

    public void buyTicket() {
        String ticket = TICKET_SERVICE.getTicket();
        System.out.println("在注冊中心拿到=>" + ticket);
    }

}

3. 注意

• 要先開啟ZooKeeper和Dubbo Admin

• 提供者的@Service注解是Dubbo包中的, 不要導錯

• 提供者使用@Component將類被SpringBoot托管, 不要用@Service

• 消費者要注冊到SpringBoot中, 使用SpringBoot的@Service

• 用dubbo的@Reference引用遠程調用的接口, 注意, 要在和遠程接口路徑相同的路徑下定義接口