java - 如何在Java中使grpc StreamObserver对象可序列化

Question

我在 Spring boot 中使用 gprc 双向流式传输聊天应用程序，从 StreamObserver<T> 开始对象用于将消息从服​​务器发送回客户端。所以，我想序列化StreamObserver<T>对象并将其转换为字节流以将其存储在 redis 或其他数据库中。但从那时起，StreamObserver<T>是一个不实现或扩展可序列化的接口(interface)。因此，我正在寻找一种如何序列化它的解决方案，因为大约有数千名用户正在使用聊天应用程序并存储 StreamObserver <T>在一些Map<String, StreamObserver<T>>这不是个好主意。

目前，我正在存储StreamObserver<T> map 中的对象。 Map<String, StreamObserver<T>>这里，map的键是聊天应用程序的用户id，值是StreamObserver对象，其中包含onNext、onError、onCompleted函数，用于从服务器向客户端发送消息

// Storing StreamObserver object with user Id
public static Map<String, StreamObserver<Chat.ChatMessageFromServer>> observersMap = new HashMap<String, StreamObserver<Chat.ChatMessageFromServer>>();


 @Override
public StreamObserver<Chat.ChatMessage> chat(final StreamObserver<Chat.ChatMessageFromServer> responseObserver) {

// responseObserver -> Storing it into a map. So, server could send message back to the client

        String user = grpcServerInterceptor.contextKey.get();
        System.out.println("");
        System.out.println("User : " + user);

        if (observersMap.get(user) == null) {

            System.out.println("New User : " + user);
            System.out.println("Adding User to observers map");
            System.out.println("");

            observersMap.put(user, responseObserver);
        } else {

            System.out.println("This User already exists in observersMap : " + user);
            System.out.println("By the way, Updating it");

            observersMap.put(user, responseObserver);
        }


  // This function sends message to client from Server
  public void sendMessageFromServerToClient(String user, String message) {

// Fetching StreamObserver from observersMap as defined above
 observersMap.get(user).onNext(Chat.ChatMessageFromServer.newBuilder().setMessage(Chat.ChatMessage.newBuilder().setTo(user).setFrom("Server").setMessage(message)).build());

            System.out.println("Pushed message to user : " + user);
            System.out.println("");

}

Answer 1

StreamObserver对应于真实TCP连接上的流。该资源无法转移到数据库。无法将其序列化到数据库以减少内存使用。