nacos搭建

nacos官方文档 https://nacos.io/zh-cn/docs/quick-start.html

下载nacos压缩包或者源码
- 压缩包地址 https://github.com/alibaba/nacos/releases
- 源码 git clone https://github.com/alibaba/nacos.git
启动项目
- 解压项目
- sh startup.sh -m standalone
关系服务
- sh shutdown.sh

nacos默认的端口号为8848
如果要修改只需要修改
nacos/conf/application.properties
文件下的server.port就可以了

搭建基于springcloud的dubbo服务

provider

pom文件配置

    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        //springboot版本 消费端的版本一致
        <spring-boot.version>2.3.7.RELEASE</spring-boot.version>
        //springcloud 版本 消费端的版本一致
        <spring-cloud-alibaba.version>2.2.2.RELEASE</spring-cloud-alibaba.version>
    </properties>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        //nacos 配置中心
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        //nacos 注册中心
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        //dubboo 依赖
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>

# 应用名称
spring.application.name=spt-user

# dubbo 协议
dubbo.protocol.id=dubbo
dubbo.protocol.name=dubbo
# dubbo 协议端口（ -1 表示自增端口，从 20880 开始）
dubbo.protocol.port=-1
# Dubbo 消费端订阅服务端的应用名，多个服务提供者用逗号分隔
# 这里订阅"自己"，会被忽略掉，请根据实际情况添加
dubbo.cloud.subscribed-services=spt-user

# dubbo 服务扫描基准包
dubbo.scan.base-packages=com.spt.user
#dubbo的注册地址如果没有 默认挂在到springcloud 所以用springcloud 就可以不用写了
#dubbo.registry.address=spring-cloud://localhost

# Nacos认证信息
spring.cloud.nacos.discovery.username=nacos
spring.cloud.nacos.discovery.password=nacos
# Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=10.73.98.45:8848
# 注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public
#server.port=8081
spring.profiles.active=public

接口+实现类

//接口类 
public interface TestFacade {

    ResponseDto<TestVo> test(TestRequest testRequest);
}

//实现类
//dubbo 注解 服务启动的时候回扫描带dubboservice的注解 然后根据我们配置的协议转换成对应的协议头开头的请求地址
@DubboService(protocol = "dubbo")
public class TestFacadeImpl implements TestFacade {

    @Autowired
    TestBiz testBiz;
    //这里就是一个简单的test方法
    @Override
    public ResponseDto<TestVo> test(TestRequest testRequest) {
        ResponseDto<TestVo> responseDto = new ResponseDto<>();
        TestVo vo = testBiz.abc(testRequest);
        responseDto.setData(vo);
        return responseDto;
    }
}

consumer

pom文件配置

       <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        //作为聚合层对外输出，需要用到controller 
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>

# 应用名称
# 应用名称
spring.application.name=api-server
# dubbo 协议
dubbo.protocol.id=dubbo
dubbo.protocol.name=dubbo
# dubbo 协议端口（ -1 表示自增端口，从 20880 开始）
dubbo.protocol.port=-1

# 这里订阅服务端的application.name
dubbo.cloud.subscribed-services=spt-user
# dubbo 服务扫描基准包
dubbo.scan.base-packages=com.spt.api
#启动的时候不校验服务端是否启动
dubbo.consumer.check=false

# Nacos帮助文档: https://nacos.io/zh-cn/docs/concepts.html
# Nacos认证信息
spring.cloud.nacos.discovery.username=nacos
spring.cloud.nacos.discovery.password=nacos
# Nacos 服务发现与注册配置，其中子属性 server-addr 指定 Nacos 服务器主机和端口
spring.cloud.nacos.discovery.server-addr=10.73.98.45:8848
# 注册到 nacos 的指定 namespace，默认为 public
spring.cloud.nacos.discovery.namespace=public

server.port=8082

服务端代码

@RestController
public class TestController {

    @DubboReference
    TestFacade testFacade;

    Logger logger = LoggerFactory.getLogger(TestController.class);

    @GetMapping(value = "test")
    public String test(Integer flag){
        TestRequest testRequest = new TestRequest();
        testRequest.setFlag(flag);
        ResponseDto<TestVo> responseDto =  testFacade.test(testRequest);
        logger.info(responseDto.toString());
        if(responseDto.isSuccess()){
            return "success";
        }
        return "fail";
    }

}

gateway

springcloud alibaba gateway 提供了一个用于在Spring WebFlux之上构建API网关的库。Spring Cloud Gateway旨在提供一种简单而有效的方法来路由到API，并为它们提供跨领域的关注点，例如：安全性，监视/指标和弹性。

pom文件

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        //最新的gateway版本提供了与sentinel合并的依赖包 不影响只是用gateway
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-gateway</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.csp</groupId>
            <artifactId>sentinel-datasource-nacos</artifactId>
        </dependency>
    </dependencies>

# 应用名称
spring.application.name=spt-gateway
server.port=8900

spring.main.allow-bean-definition-overriding=true
#nacos注册中心配置
spring.cloud.nacos.discovery.username=nacos
spring.cloud.nacos.discovery.password=nacos
spring.cloud.nacos.discovery.server-addr=10.73.98.45:8848
spring.cloud.nacos.discovery.namespace=public

spring.cloud.gateway.discovery.locator.lower-case-service-id=true
#是否开始服务注册和发现功能，以为我们是要发现api-server服务，所以开启
spring.cloud.gateway.discovery.locator.enabled=true

//具体的路由规则
//id是随意定义的 sentinel配置限流能用到id
spring.cloud.gateway.routes[0].id=web
//lb 表示挂载到注册中心，会从注册中心找到api-server的服务列表，然后进行路由，默认问轮询
spring.cloud.gateway.routes[0].uri=lb://api-server
//表示test开头的会请求转发到 api-server
spring.cloud.gateway.routes[0].predicates[0]=Path=/test/acb/**
//表示请求转发的时候会去掉最前面的一级目录  ip:port/acb/**
spring.cloud.gateway.routes[0].filters[0]=StripPrefix=1

spring.cloud.gateway.routes[1].id=auth
spring.cloud.gateway.routes[1].uri=lb://spt-auth
spring.cloud.gateway.routes[1].predicates[0]=Path=/auth/**
spring.cloud.gateway.routes[1].filters[0]=StripPrefix=0
#spring.cloud.gateway.routes[1].filters[1]=LogFilterFactory=true

#这块是sentinel的配置 
spring.cloud.sentinel.transport.dashboard=127.0.0.1:8085
spring.cloud.sentinel.datasource.ds.nacos.server-addr=10.73.98.45:8848
spring.cloud.sentinel.datasource.ds.nacos.data-id=sentinel
spring.cloud.sentinel.datasource.ds.nacos.username=nacos
spring.cloud.sentinel.datasource.ds.nacos.password=nacos
spring.cloud.sentinel.datasource.ds.nacos.group-id=DEFAULT_GROUP
spring.cloud.sentinel.datasource.ds.nacos.data-type=json
spring.cloud.sentinel.datasource.ds.nacos.rule-type=degrade

Golbalfilter 在gateway 中基本都会用到，一般会作为鉴权，请求url，参数日志打印等


@Component("authFilter")
public class Authfilter implements GlobalFilter, Ordered {

    Logger logger = LoggerFactory.getLogger(this.getClass());
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {

        String path = exchange.getRequest().getURI().getPath();
        logger.info("path:{}",path);
        //过滤不需要拦截的url
        if(path.startsWith("/auth/login")){
            Mono<Void> filter = chain.filter(exchange);
            return filter;
        }
        //token校验
        ServerHttpRequest request = exchange.getRequest();
        HttpHeaders header = request.getHeaders();
        String token = header.getFirst("token");
        System.out.println("token="+token);
        ServerHttpResponse response = exchange.getResponse();
        if (StringUtils.isBlank(token)) {
            System.out.println("token not found");
            response.setStatusCode(HttpStatus.UNAUTHORIZED);
            return response.setComplete();
        }


        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        return 10;
    }
}

@Configuration
public class GatewayConfiguration {

    @Autowired
    private Authfilter authfilter;

}

springcloud gateway+nacos+dubbo

springcloud gateway+nacos+dubbo

nacos搭建

nacos官方文档 https://nacos.io/zh-cn/docs/quick-start.html

搭建基于springcloud的dubbo服务

provider

pom文件配置

接口+实现类

consumer

pom文件配置

服务端代码

gateway

pom文件

Golbalfilter 在gateway 中基本都会用到，一般会作为鉴权，请求url，参数日志打印等

推荐阅读更多精彩内容