微服務系統中服務之間的通訊方式-java教程-PHP中文網

微服務系統中服務之間的通訊方式

PHPz

發布： 2024-08-17 18:48:15

原創

626 人瀏覽過

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，則需要轉換層。

部署和管理可能更加複雜。