在 Spring Cloud 中，主要有以下几种通信方式：
以 Dubbo 在 Spring Cloud 中的应用为例：
Dubbo 是一个高性能的 RPC 框架，可以与 Spring Cloud 集成。通过 Dubbo，服务提供者和服务消费者之间可以进行高效的远程方法调用。
优点：
性能高，通常比基于 HTTP 的通信方式更快。
可以支持多种序列化方式，如 Hessian、JSON、Protobuf 等，满足不同场景的需求。
缺点：
相对复杂，需要引入额外的框架和依赖。
与特定的 RPC 框架绑定，可能会限制技术选型的灵活性。
工作原理：
各个微服务通过发送和接收消息来进行通信。服务生产者将消息发送到消息队列，服务消费者从消息队列中获取消息并进行处理。
例如，一个订单服务在订单创建成功后，将订单信息发送到消息队列，库存服务从消息队列中获取订单信息并进行库存扣减操作。
优点：
解耦服务之间的直接依赖，提高系统的可扩展性和容错性。
可以实现异步通信，提高系统的响应速度和吞吐量。
缺点：
引入了额外的中间件，增加了系统的复杂性。
需要处理消息的顺序性、重复消费等问题。
总之，Spring Cloud 中可以根据具体的业务需求和场景选择合适的通信方式。HTTP 的 RESTful API 简单易用，适合大多数场景；RPC 通信性能高，适合对性能要求较高的场景；消息队列适合解耦和异步通信的场景。
RestTemplate 方式
Feign 的方式
第一种方式 直接使用 RestTemplate ，url 写死
服务端编写
/**
用来测试与 order 服务的连接
@author ccyang
@date 2018/7/1 16:06 */ @RestController public class serverController { @GetMapping(“/getMsg”) public String getMsg(){ return “this is product’ msg”; } }
客户端编写
/**
* @author ccyang
* @date 2018/7/1 16:13
*/
@RestController
@Slf4j
public class clientController {
@GetMapping("/getProductMsg")
public String getProductMsg(){
RestTemplate restTemplate = new RestTemplate();
String response = restTemplate.getForObject("http://localhost:8080/getMsg",String.class);
log.info("response = {}" , response);
return response;
}
}
然后去访问 即可。
因为服务端的 api 被硬编码在客户端，因此有两个缺点： – 当注册中心有很多服务时，我们可能不知道我们需要的服务由谁提供、api是多少，因此就可能无法调用到服务。 –当某个服务部署了多个，例如 api 是： “localhost:9080/getMsg，localhost:9081/getMsg “，那么此时就需要负载均衡，这种硬编码显然不符合场景。
/**
测试获取 product服务的msg
@author ccyang
@date 2018/7/1 16:13 */ @RestController @Slf4j public class clientController {
@Autowired private LoadBalancerClient loadBalancerClient;
@GetMapping(“/getProductMsg”) public String getProductMsg(){
RestTemplate restTemplate = new RestTemplate();
ServiceInstance serviceInstance = loadBalancerClient.choose("PRODUCT"); // serviceId 为提供服务的应用名
String url = String.format("http://%s:%s",serviceInstance.getHost(),serviceInstance.getPort() + "/getMsg");
String response = restTemplate.getForObject( url, String.class);
log.info("response = {}" , response);
return response;
123456 } }
缺点是每次调用服务都要这样写，编码很麻烦。
第三种方式 通过 @LoadBalanced，可在restTemplate 直接使用应用名字。
@Component public class RestTemplateConfig { @Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); } }
@RestController @Slf4j public class clientController {
@Autowired
private RestTemplate restTemplate;
@GetMapping("/getProductMsg")
public String getProductMsg(){
String response = restTemplate.getForObject( "http://PRODUCT/getMsg", String.class); // 通过应用名进行访问
log.info("response = {}" , response);
return response;
}
12345678910 }
声明式 REST客户端（伪 RPC）
采用了基于接口的注解
先看看如何使用 Feign: \1. 添加依赖
<!-- add feign , note: must add version -->
<dependency>
<groupId>org.springframework.cloud</groupId >
<artifactId>spring-cloud-starter-feign</artifactId>
<version>1.4.4.RELEASE</version>
</dependency>
2. 添加注解到主类上
@EnableFeignClients
3. 定义要调用的接口
@FeignClient(name = "product") // 服务名
public interface ProductClient {
@GetMapping("/getMsg") // 这里要和 Product服务提供的接口一致
String productMsg();
}
4. 在该使用的地方使用注解中提供的方法
@RestController
@Slf4j
public class clientController {
@Autowired
private ProductClient productClient; // 有报错，不影响
@GetMapping("/getProductMsg")
public String getProductMsg(){
String response = productClient.productMsg();
log.info("response = {}" , response);
return response;
}
}
Feign 可以看做是一个伪 RPC，而且HTTP远程调用对开发者完全透明。
RestTemplate 内部使用 Ribbon做负载均衡 Feign 内部也是使用的Ribbon做负载均衡
参考：