SpringCloud 应用之间的通信

快来打我* 2021-12-17 13:11 288阅读 0赞

有2种方式：

**1.通过 restTemlate方式**

直接restTemplate对象。将url写死即可。

RestTemplate restTemplate = new RestTemplate();
    String response = restTemplate.getForObject("http://localhost:8080/msg", String.class);
    //从http://localost:8080/msg获取string信息。

优点：简单直接，缺点：url写死，耦合了。以后想动，必须修改代码。

借用 ServiceInstance serviceInstance =  loadBalancerClient.choose("PRODUCT");，url不写死

//先注入对象,获取Host和端口，其次再通过restTemplate对象去通信。
     @Autowired
    private LoadBalancerClient loadBalancerClient;
    ServiceInstance serviceInstance =  loadBalancerClient.choose("PRODUCT");，url不写死
    RestTemplate restTemplate = new RestTemplate();
    ServiceInstance serviceInstance =  loadBalancerClient.choose("PRODUCT");
    String url=String.format("http://%s:%s",serviceInstance.getHost(),serviceInstance.getPort()+"/msg");
    String response = restTemplate.getForObject(url,String.class);

//先构建一个RestTemplateConfig类
    @Component
    @Slf4j
    public class RestTemplateConfig {
    
    
        @Bean
        @LoadBalanced
        public RestTemplate restTemplate(){
            return new RestTemplate();
        }
    }
     
    //再调用restTemplae去获取
    @Autowired
     private RestTemplate restTemplate;
     String response = restTemplate.getForObject("http://PRODUCT/msg", String.class);

**通过Feign通信:**

1.添加依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-feign</artifactId>
            </dependency>

2.给启动项加上注解

@EnableFeignClients

3.增加一个注解

@FeignClient(name="product")           //访问eruke 中的product应用
    public interface ProductClient {        
    
    
        @GetMapping("/msg")                //访问路径基于  /msg下的
        String productMsg();
    
    }

4.使用注入接口对象即可，

@RestController
    @Slf4j
    public class ClientController {
    
        @Autowired
        private ProductClient productClient;   //注入接口
    
        @GetMapping("/getProductMsg")
        public String getProductMsg(){        
    
            String response = productClient.productMsg();      //以对象的形式去调用
            log.info("resonse={}",response);
            return response;
    
        }
    
    }

优点：以一个对象去调用，缺点：暂时不知，肯定有的。^ \_ ^

易错的2个点：

1个服务去调用另外的一个服务，如果报404,那么就是这个服务Feign去调用另外服务的路径极易写错。

2.就是@PostMapping，在参数为@RresponseBody情况下，必须用。