SpringCloud通過Nacos實現(xiàn)注冊中心與遠程服務調用詳解流程

更新時間：2022年07月12日 10:36:00 作者：有頭發(fā)的程序猿!

如果不滿足eureka注冊中心，那么本文記錄的Nacos是不二之選。本文主要記錄Springboot基于Nacos實現(xiàn)注冊中心以及遠程服務調用

1. 基于Nacos實現(xiàn)服務注冊與發(fā)現(xiàn)

基于pring-boot-starter-parent 2.6.8，pring-cloud-dependencies 2021.0.3，order服務和user服務

1.1 pom依賴

<!--服務注冊與發(fā)現(xiàn)-->
<dependency>
	<groupId>com.alibaba.cloud</groupId>
	<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
	<version>2021.0.1.0</version>
</dependency>
<!--遠程服務調用負載均衡-->
<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-loadbalancer</artifactId>
</dependency>

1.2 yaml配置

order服務application.yml

spring:
application:
name: orderservice
cloud:
#找對應網(wǎng)段的網(wǎng)卡不配置內部服務就走外網(wǎng)
inetutils:
preferred-networks: 192.168.0
nacos:
discovery:
server-addr: 192.168.0.221:8848

user服務application.yml

spring:
application:
name: userservice
cloud:
#找對應網(wǎng)段的網(wǎng)卡不配置內部服務就走外網(wǎng)
inetutils:
preferred-networks: 192.168.0
nacos:
discovery:
server-addr: 192.168.0.221:8848

1.3 添加啟動注解

@EnableDiscoveryClient，需要注冊到Nacos的服務都需要添加

@SpringBootApplication
@EnableDiscoveryClient
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }
}

1.4 啟動服務查看控制臺

控制臺地址http://192.168.0.221:8848/nacos，賬號密碼都是nacos，查看服務列表

服務詳情圖

如果未配置preferred-networks，ip則顯示外網(wǎng)ip，也會用于服務調用

2.基于Nacos實現(xiàn)遠程服務調用

2.1 客戶端創(chuàng)建RestTemplate Bean

	@LoadBalanced    // 開啟負載均衡策略
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

2.2 客戶端調用代碼

    @Autowired
    RestTemplate restTemplate;
    @Autowired
    private DiscoveryClient discoveryClient;
    @GetMapping("/test")
    public String test() throws Exception {
        //可以獲取到對應服務的列表 服務名 ip 端口均可從這里面獲取到 也可以自己決定調用順序
        List<ServiceInstance> instances = discoveryClient.getInstances("userservice");
		//get方式調用 
        String template = restTemplate.getForObject("http://userservice/getTime/1123?name=jack", String.class);
        Map<String, Object> resMap = new HashMap<>();
        resMap.put("aaaa", "bbbb");
        //post調用方式
        RequestEntity<Map<String, Object>> requestEntity = RequestEntity
                .post("http://userservice/postTime")
                .contentType(MediaType.APPLICATION_JSON)
                .body(resMap);
        ResponseEntity<Map> responseEntity = restTemplate.exchange(requestEntity, Map.class);]
        log.info("rest -- {}", template + ":" + responseEntity.getBody());
        return template + ":" + responseEntity.getBody();
    }

2.3 服務端暴露接口

@GetMapping("/getTime/{uuid}")
public String getTime(@PathVariable String uuid, @RequestParam String name) {
    return new Date().getTime() + ":" + uuid + ":" + name;
}
@PostMapping("/postTime")
public Map<String, Object> getTime(@RequestBody Map<String, Object> params) {
    params.put("time", new Date().getTime());
    return params;
}