当前位置：首页 > 文章列表 > 文章 > java教程 > 微服务系统中服务之间的通信方式

微服务系统中服务之间的通信方式

来源：dev.to 2024-08-17 19:36:52 0浏览收藏

小伙伴们对文章编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《微服务系统中服务之间的通信方式》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

1. 同步通讯

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

微服务系统中服务之间的通信方式

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，则需要翻译层。

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