【架构之路】微服务中常用的几种通信方式

avatar
作者
猴君
阅读量:2

2024年，计算机相关专业还值得选择吗？

579a429daf314744b995f37351b46548

强烈推荐

前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站:人工智能

b004071ozy_05_amzn

引言

微服务架构由于其灵活性、高可扩展性和易维护性，已成为构建复杂系统的主流选择。

微服务架构将系统拆分为多个独立的服务，每个服务负责特定的功能，并通过各种通信方式进行协作。

这些通信方式在确保系统高效、可靠运行的过程中起着至关重要的作用。

本文将介绍几种常见的微服务通信方式，包括HTTP REST、gRPC、消息队列和WebSocket，并通过Java示例说明它们的应用场景和实现方法。

几种通信方式

在微服务架构中，服务之间的通信是关键组件之一。常见的通信方式包括HTTP REST、gRPC、消息队列、以及基于WebSocket的通信。下面举例说明这些通信方式。

1. HTTP REST

HTTP REST是一种广泛使用的同步通信方式。每个微服务通过HTTP请求相互通信，通常使用JSON作为数据格式。

示例：

假设有两个微服务，一个用于用户管理（User Service），另一个用于订单管理（Order Service）。Order Service需要从User Service获取用户信息。

User Service:

@RestController @RequestMapping("/users") public class UserController {      @GetMapping("/{id}")     public ResponseEntity<User> getUserById(@PathVariable String id) {         // 假设从数据库获取用户信息         User user = userService.findUserById(id);         return ResponseEntity.ok(user);     } }

Order Service:

@Service public class UserServiceClient {      private final RestTemplate restTemplate;      @Autowired     public UserServiceClient(RestTemplate restTemplate) {         this.restTemplate = restTemplate;     }      public User getUserById(String userId) {         String url = "http://USER-SERVICE/users/" + userId;         return restTemplate.getForObject(url, User.class);     } }

配置RestTemplate:

@Configuration public class RestTemplateConfig {      @Bean     public RestTemplate restTemplate() {         return new RestTemplate();     } }
2. gRPC

gRPC是Google开源的一个高性能、通用的RPC框架，使用Protocol Buffers作为接口定义语言，并支持多种编程语言。

示例：

假设有两个微服务，一个用于用户管理（User Service），另一个用于订单管理（Order Service）。Order Service需要从User Service获取用户信息。

User Service:

1.定义.proto文件：

syntax = "proto3";  option java_package = "com.example.userservice"; option java_outer_classname = "UserServiceProto";  service UserService {     rpc GetUser (UserRequest) returns (UserResponse) {} }  message UserRequest {     string id = 1; }  message UserResponse {     string id = 1;     string name = 2;     string email = 3; }

2.实现服务端：

public class UserServiceImpl extends UserServiceGrpc.UserServiceImplBase {      @Override     public void getUser(UserRequest request, StreamObserver<UserResponse> responseObserver) {         // 假设从数据库获取用户信息         UserResponse response = UserResponse.newBuilder()                 .setId(request.getId())                 .setName("John Doe")                 .setEmail("john.doe@example.com")                 .build();         responseObserver.onNext(response);         responseObserver.onCompleted();     } }

3.配置并启动gRPC服务器：

public class GrpcServer {      public static void main(String[] args) throws IOException, InterruptedException {         Server server = ServerBuilder.forPort(8080)                 .addService(new UserServiceImpl())                 .build();          server.start();         System.out.println("Server started on port 8080");         server.awaitTermination();     } }

Order Service:

1.创建gRPC客户端：

public class UserServiceClient {      private final UserServiceGrpc.UserServiceBlockingStub userServiceStub;      public UserServiceClient() {         ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 8080)                 .usePlaintext()                 .build();         userServiceStub = UserServiceGrpc.newBlockingStub(channel);     }      public UserResponse getUserById(String userId) {         UserRequest request = UserRequest.newBuilder().setId(userId).build();         return userServiceStub.getUser(request);     } }
3. 消息队列

消息队列是一种异步通信方式，常用的消息队列系统有RabbitMQ、Apache Kafka等。消息队列可以解耦生产者和消费者，实现异步处理。

示例：

假设有两个微服务，一个用于订单管理（Order Service），另一个用于通知服务（Notification Service）。订单服务在订单创建后发送消息到消息队列，通知服务接收并处理消息。

Order Service:

@Service public class OrderService {      private final RabbitTemplate rabbitTemplate;      @Autowired     public OrderService(RabbitTemplate rabbitTemplate) {         this.rabbitTemplate = rabbitTemplate;     }      public void createOrder(Order order) {         // 创建订单逻辑         rabbitTemplate.convertAndSend("order.exchange", "order.created", order);     } }

Notification Service:

@Service public class NotificationService {      @RabbitListener(queues = "order.queue")     public void handleOrderCreated(Order order) {         // 处理订单创建通知         System.out.println("Received order: " + order);     } }

配置RabbitMQ:

@Configuration public class RabbitMQConfig {      @Bean     public Queue queue() {         return new Queue("order.queue");     }      @Bean     public TopicExchange exchange() {         return new TopicExchange("order.exchange");     }      @Bean     public Binding binding(Queue queue, TopicExchange exchange) {         return BindingBuilder.bind(queue).to(exchange).with("order.created");     } }

4. WebSocket

WebSocket是一种双向通信协议，适用于需要实时通信的场景。

示例：

假设有一个聊天应用，两个微服务分别处理用户和聊天信息。

Chat Service:

@Configuration @EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer {      @Override     public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {         registry.addHandler(new ChatWebSocketHandler(), "/chat");     } }  @Component public class ChatWebSocketHandler extends TextWebSocketHandler {      @Override     public void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {         // 处理收到的消息         session.sendMessage(new TextMessage("Received: " + message.getPayload()));     } }

应用场景

不同的通信方式适用于不同的应用场景，每种方式都有其优缺点和适用领域。以下是对上述几种通信方式的应用场景的说明：

1. HTTP REST

应用场景：

  • Web服务与API接口：HTTP REST是构建Web服务和API接口的首选方法，广泛应用于提供对外部系统的访问接口。
  • 同步请求响应：适用于需要立即得到响应的请求，比如用户查询、订单查询等。
  • 简单易用：对开发者友好，易于实现和调试，适合快速开发。

示例场景：

  • 用户注册、登录等操作。

  • 产品信息查询，订单管理系统。

2. gRPC

应用场景：

  • 高性能通信：适用于需要高性能、低延迟通信的场景，如微服务之间的大量数据传输。
  • 多语言支持：适用于多语言环境，因为gRPC支持多种编程语言。
  • 严格的接口定义：适用于需要严格接口和数据类型约束的场景，通过Protocol Buffers定义接口。

示例场景：

  • 实时数据处理，如在线游戏、实时数据分析。

  • 微服务内部通信，如电商系统中的订单服务与库存服务之间的通信。

3. 消息队列

应用场景：

  • 异步处理：适用于需要异步处理的场景，避免长时间的同步等待。
  • 解耦系统：适用于希望解耦生产者和消费者的场景，使得系统更加灵活和可扩展。
  • 任务队列：适用于需要将任务放入队列中逐步处理的场景，如邮件发送、日志处理。

示例场景：

  • 订单创建后发送通知或进行库存更新。

  • 用户注册后发送欢迎邮件。

  • 日志收集与处理系统。

4. WebSocket

应用场景：

  • 实时通信：适用于需要实时双向通信的场景，如聊天应用、在线游戏、实时协作工具。
  • 低延迟要求：适用于对延迟有严格要求的应用，能够提供持续的低延迟连接。
  • 状态保持：适用于需要保持连接状态的应用，如实时数据更新。

示例场景：

  • 聊天应用，如即时消息系统。

  • 实时交易平台，如股票交易、加密货币交易。

  • 实时协作工具，如在线文档协作、实时编辑器。

场景应用总结
  • HTTP REST适用于简单的请求响应模型和对外提供API的场景，易于实现和使用。
  • gRPC适用于需要高性能通信和严格接口定义的场景，适合多语言环境和实时数据处理。
  • 消息队列适用于异步处理和解耦的场景，适合任务队列和事件驱动架构。
  • WebSocket适用于需要实时双向通信和低延迟的场景，适合实时应用和需要保持连接状态的场景。

根据具体的业务需求和性能要求，开发者可以选择最适合的通信方式来实现微服务之间的通信。

总结

微服务通信方式的选择在很大程度上影响系统的性能、可靠性和扩展性。

通过了解和掌握HTTP REST、gRPC、消息队列和WebSocket等不同通信方式的特点和应用场景，开发者可以根据具体业务需求选择最合适的通信方式，从而构建出高效、灵活和可扩展的微服务系统。

在实际应用中，可能需要结合多种通信方式，以发挥各自的优势，满足系统的不同需求。

强烈推荐

前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站:人工智能

b004071ozy_05_amzn

专栏集锦

大佬们可以收藏以备不时之需：

Spring Boot 专栏：http://t.csdnimg.cn/peKde

ChatGPT 专栏：http://t.csdnimg.cn/cU0na

Java 专栏：http://t.csdnimg.cn/YUz5e

Go 专栏：http://t.csdnimg.cn/Jfryo

Netty 专栏：http://t.csdnimg.cn/0Mp1H

Redis 专栏：http://t.csdnimg.cn/JuTue

Mysql 专栏：http://t.csdnimg.cn/p1zU9

架构之路 专栏：http://t.csdnimg.cn/bXAPS

写在最后

感谢您的支持和鼓励！ 😊🙏

如果大家对相关文章感兴趣，可以关注公众号"架构殿堂"，会持续更新AIGC，java基础面试题, netty, spring boot, spring cloud等系列文章，一系列干货随时送达!

如果有项目或者毕设合作，请V:fengyelin8866,备注毕设

相关阅读
  1. 如何查看和设置我的Android N设备的权限？
  2. 如何在安卓手机上自定义应用图标？
  3. 如何在安卓微信中同时听语音和查看图片？
  4. 华为哪些设备将支持升级至安卓7.0？
  5. 微信安卓软件中Q10功能有哪些独特之处？
  6. 安卓用户如何挑选最佳视频播放器应用？
  7. 安卓系统中用户文件目录的确切位置是什么？
  8. 小米4用户如何安全升级到安卓8.0系统？
  9. 如何成功将魅蓝5升级至安卓原生7.0版本？
  10. 16GB存储的安卓手机是否能满足日常需求？

广告一刻

为您即时展示最新活动产品广告消息，让您随时掌握产品活动新动态！