微服务系统中服务之间的通信方式-java教程-PHP中文网

1. 同步通讯

同步通信涉及实时交互，其中一个服务向另一个服务发送请求并暂停其操作，直到收到响应。 REST API 和 gRPC 是用于促进此类通信的常用协议。

Ways of communication between services in a Microservice system

1.1 REST API

RESTful API（表述性状态传输）是微服务系统中服务相互通信最常用的方法之一。 REST 利用 HTTP/HTTPS 和 JSON 或 XML 格式进行数据交换。

通常，服务通过直接调用另一个服务的 API 来相互交互。

请求和响应示例：

GET /users/12345 HTTP/1.1
Host: api.userservice.com
Accept: application/json
Authorization: Bearer your-access-token

{
  "userId": "12345",
  "name": "Michel J",
  "email": "MJ@example.com",
  "address": "Mountain View, Santa Clara, California"
}

登录后复制

源代码示例

import org.springframework.web.client.RestTemplate;
import org.springframework.http.ResponseEntity;

public class OrderService {

    private final RestTemplate restTemplate = new RestTemplate();
    private final String userServiceUrl = "https://api.userservice.com/users/";

    public User getUserById(String userId) {
        String url = userServiceUrl + userId;
        ResponseEntity<User> response = restTemplate.getForEntity(url, User.class);
        return response.getBody();
    }
}

登录后复制

优点：

易于部署并与各种语言和工具集成。

能够轻松使用测试和监控工具。

缺点：

由于其同步性质，对于高速要求可能效率不高。

在处理网络错误或断开连接时可能会遇到困难。

1.2 通用RPC

gRPC，全称Google Remote procedure Call，是一个高性能、开源的通用RPC框架。它利用 HTTP/2 进行高效的数据传输，并且通常依赖于协议缓冲区（一种语言中立、平台中立、可扩展的机制，用于序列化结构化数据）来定义发送和接收的数据的结构。

示例，协议缓冲区的定义

syntax = "proto3";

package userservice;

// Define message User
message User {
    string userId = 1;
    string name = 2;
    string email = 3;
    string address = 4;
}

// Define service UserService
service UserService {
    rpc GetUserById (UserIdRequest) returns (User);
}

// Define message UserIdRequest
message UserIdRequest {
    string userId = 1;
}

登录后复制

对于用户管理服务，您应该实现一个遵循 .proto 文件中提供的服务定义的 gRPC 服务器。这包括创建必要的服务器端逻辑来处理传入的 gRPC 请求并生成适当的响应。

import io.grpc.stub.StreamObserver;
import userservice.User;
import userservice.UserIdRequest;
import userservice.UserServiceGrpc;

public class UserServiceImpl extends UserServiceGrpc.UserServiceImplBase {

    @Override
    public void getUserById(UserIdRequest request, StreamObserver<User> responseObserver) {
        // Assuming you have a database to retrieve user information.
        User user = User.newBuilder()
                .setUserId(request.getUserId())
                .setName("Michel J")
                .setEmail("MJ@example.com")
                .setAddress("Mountain View, Santa Clara, California")
                .build();

        responseObserver.onNext(user);
        responseObserver.onCompleted();
    }
}

import io.grpc.Server;
import io.grpc.ServerBuilder;

public class UserServer {
    public static void main(String[] args) throws Exception {
        Server server = ServerBuilder.forPort(9090)
                .addService(new UserServiceImpl())
                .build()
                .start();

        System.out.println("Server started on port 9090");
        server.awaitTermination();
    }
}

登录后复制

优点：

由于使用 HTTP/2 和 Protocol Buffers，因此具有高性能和带宽效率。

支持多种编程语言，具有良好的扩展性。

缺点：

如果服务不支持 gRPC，则需要转换层。

部署和管理可能更加复杂。