微服務註冊中心Nacos入門

服務治理

服務治理的核心由三部分組成：服務提供者、服務消費者、註冊中心。在分布式系統架構中，每個微服務在啟動時，將自己的信息存儲在註冊中心，叫做服務註冊。服務消費者從註冊中心獲取服務提供者的網絡信息，通過該信息調用服務，叫做服務發現。

服務提供者&服務消費者

服務的提供者&服務的消費者是相對的概念：

比如用戶服務調用訂單服務，那麼用戶服務是訂單服務的消費者，訂單服務是用戶服務的提供者。但是對於訂單服務調用庫存服務，那麼訂單服務就成為庫存服務消費者，庫存服務就是訂單服務的提供者。Nacos集群部署

本例搭建是偽集群，在一臺虛擬機上起3個nacos服務，使用nginx做負載均衡。

下載地址：https://github.com/alibaba/Nacos/releases

tar -xzvf nacos-server-1.1.4.tar.gz

編輯conf/application.properties文件：

#mysql資料庫連接信息，需要自己創建資料庫,sql腳本在conf/nacos-mysql.sql
server.port=8849  #3個nacos服務埠號分別為8849，8850，8851
spring.datasource.platform=mysql
db.num=1
db.url.0=jdbc:mysql://192.168.1.14:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true
db.user=root
db.password=123456

將conf/cluster.conf.example改為conf/cluster.conf，編輯文件：

192.168.1.5:8849
192.168.1.5:8850
192.168.1.5:8851

依次使用sh /bin/startup.sh命令啟動。

nginx配置：

events{}
http {
upstream nacos {
server 192.168.1.5:8849;
server 192.168.1.5:8850;
server 192.168.1.5:8851;
}
server {
listen 8848; #客戶端訪問地址
location / {
proxy_pass http://nacos;
}
}
}

輸入http://192.168.1.5:8848 登錄nacos，用戶名nacos,密碼nacos。

服務接入配置中心

引入依賴：

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-alibaba-nacos-discovery</artifactId>
</dependency>

加入註解：（以前低版本需要寫，現在其實不需要）

package com.tuling;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient  //高版本可以不寫
public class Tulingvip01MsAlibabaNacosClientOrderApplication {

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

寫配置文件：

spring:
  datasource:
    druid:
      username: root
      password: 123456
      jdbcUrl: jdbc:mysql://192.168.1.14:3306/tuling-ms-alibaba?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8&useSSL=false
      driverClassName: com.mysql.jdbc.Driver
      initialSize: 5
      minIdle: 5
      maxActive: 20
      maxWait: 60000
      timeBetweenEvictionRunsMillis: 60000
      minEvictableIdleTimeMillis: 300000
      validationQuery: SELECT 1 FROM DUAL
      testWhileIdle: true
      testOnBorrow: false
      testOnReturn: false
      poolPreparedStatements: true
      filters: stat,wall #\u914D\u7F6E\u8FC7\u6EE4\u5668
      maxPoolPreparedStatementPerConnectionSize: 20
      useGlobalDataSourceStat: true
      connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
  cloud:
    nacos:
      discovery:
        server-addr: 192.168.1.5:8848
        #環境隔離
        namespace: 13499a23-e36e-41e7-8f8b-bd071bb8708e
        #分組隔離
        group: pay
        #cluster不相同可以調到，但是優先調本集群
        cluster-name: BJ

  application:
    name: order-center
server:
  port: 8080

啟動order-center和product-center服務，驗證兩個服務註冊到nacos上：

服務Controller代碼

order-center通過discoveryClient.getInstances獲取product-center服務信息，然後調用product-center去查詢資料庫信息，最後返回信息給客戶端。

package com.tuling.controller;

import com.tuling.entity.OrderInfo;
import com.tuling.entity.ProductInfo;
import com.tuling.mapper.OrderInfoMapper;
import com.tuling.vo.OrderVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.List;

@RestController
public class OrderInfoController {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private OrderInfoMapper orderInfoMapper;

    @Autowired
    private DiscoveryClient discoveryClient;


    @RequestMapping("/selectOrderInfoById/{orderNo}")
    public Object selectOrderInfoById(@PathVariable("orderNo") String orderNo) {

        OrderInfo orderInfo = orderInfoMapper.selectOrderInfoById(orderNo);
        if(null == orderInfo) {
            return "根據orderNo:"+orderNo+"查詢沒有該訂單";
        }

        /**
         * 從nacos server獲取 product-info的地址
         */
        List<ServiceInstance> serviceInstanceList =  discoveryClient.getInstances("product-center");

        if(null == serviceInstanceList || serviceInstanceList.isEmpty()) {
            return "用戶微服務沒有對應的實例可用";
        }
        /**
         * 獲取第0個元素
         */
        String targetUri = serviceInstanceList.get(0).getUri().toString();

        ResponseEntity<ProductInfo> responseEntity= restTemplate.getForEntity(targetUri+"/selectProductInfoById/"+orderInfo.getProductNo(), ProductInfo.class);

        ProductInfo productInfo = responseEntity.getBody();

        if(productInfo == null) {
            return "沒有對應的商品";
        }

        OrderVo orderVo = new OrderVo();
        orderVo.setOrderNo(orderInfo.getOrderNo());
        orderVo.setUserName(orderInfo.getUserName());
        orderVo.setProductName(productInfo.getProductName());
        orderVo.setProductNum(orderInfo.getProductCount());

        return orderVo;
    }

    @GetMapping("/getServiceList")
    public List<ServiceInstance> getServiceList() {
        List<ServiceInstance> serviceInstanceList =  discoveryClient.getInstances("order-center");
        return serviceInstanceList;
    }
}

調用order-center接口查詢訂單信息：