表更改后立即使用 gRPC 传输数据库数据-Golang-PHP中文网

表更改后立即使用 gRPC 传输数据库数据

WBOY

发布： 2024-02-05 11:49:31

转载

505人浏览过

表更改后立即使用 grpc 传输数据库数据

问题内容

我正在使用 go、grpc 和 postgres 制作任务列表。

如何在调用 postitem 插入新数据时自动流式传输数据？我需要订阅 postgres 还是可以在不订阅或发布订阅的情况下完成此操作？

// protobuf 架构

syntax = "proto3";

package tasklist;

import "google/protobuf/empty.proto";

service todolist {
  rpc gettasks(google.protobuf.empty) returns (stream gettasksresponse) {}
  rpc postitem(postitemrequest) returns (posttaskrequest) {}
}


message task {
  int64 id = 1;
  string name = 2;
}

message gettasksresponse {
  task task = 1;
}

message posttaskrequest {
  task task = 1;
}

message postitemresponse {
  bool result = 1;
}

登录后复制

// postgres 表架构

教育培训机构网站整站源码

解压压缩包，上传到FTP空间，按正常安装织梦步骤进行安装；安装完成以后，恢复数据库，在系统设置里指定模板文件夹，然后再更新下缓存，生成下首页、内容页及列表页就可以使用了，首页调用，有些地方需要修改一下调用ID。

183

查看详情

create table task (
  id integer not null primary key,
  name varchar(10) not null
);

登录后复制

// 继续

func (s *server) GetTasks(_ *empty.Empty, stream pb.TaskList_GetTasksServer) error {
    // How can I steam data as soon as `PostTask` is called to update db? <- <-
    for _, r := range s.requests {
        // stream data
    }
}

func (s *server) PostTask(ctx context.Context, r *pb.PostTaskRequest) (*pb.PostTaskResponse, error) {
    // update Postgres here
    return &pb.PostItemResponse{Result: true}, nil
}

登录后复制

正确答案

我猜 s.requests 类似于 chan task。因此，在成功 // update postgres here 之后，您可以在 chan 中发送您的请求。

func (s *server) PostTask(ctx context.Context, r *pb.PostTaskRequest) (*pb.PostTaskResponse, error) {
    postTask := toDomain(r)
    err := s.service.UpdateTask(ctx, postTask)
    if err != nil {
        return nil, status.Error(codes.Internal, err.Error())
    }
    s.requests <- postTask
    return &pb.PostItemResponse{Result: true}, nil
}

登录后复制

以上就是表更改后立即使用 gRPC 传输数据库数据的详细内容，更多请关注php中文网其它相关文章！