How to implement Asynchronous chain request by grpc-rpc - Codes Helper - Programming Question Answer

How to implement Asynchronous chain request by grpc-rpc

A chained call to a grpc request needs to be implemented in the business. The service flow is as follows:

client- > serverA- > serverB

the code to create the CallData, on the grpc server is as follows:

class CallData {
    public:
        CallData(Save::AsyncService *service, ServerCompletionQueue *completionQueue) :
                status_(CREATE),
                service_(service),
                completionQueue_(completionQueue),
                responder_(&context_) {
            //Invoke the sereving logic right away
            Proceed();
        }

        void Proceed() {
            if (CREATE == status_) {
                status_ = PROCESS;
                service_->Request(&context_, &request_, &responder_, completionQueue_, completionQueue_, this);
            } else if (PROCESS == status_) {
                new CallData(service_, completionQueue_, sender_);
                
                //
                
                status_ = FINISH;
                responder_.Finish(reply_, Status::OK, this);
            } else {
                GPR_ASSERT(FINISH == status_);
                delete this;
            }
        }

    private:
        enum CallStatus {
            CREATE, PROCESS, FINISH
        };
        CallStatus status_;
        
        //
    };

Proceed in CallData did not think of how to proceed with the next asynchronous request and how to handle the returned result. Ask for advice!

Grpc

Mar.04,2021

class CallData {

public:
    CallData(Save::AsyncService *service, ServerCompletionQueue *completionQueue) :
            status_(CREATE),
            service_(service),
            completionQueue_(completionQueue),
            responder_(&context_) {
        //Invoke the sereving logic right away
        Proceed();
    }

    void Proceed() {
        if (CREATE == status_) {
            status_ = PROCESS;
            service_->Request(&context_, &request_, &responder_, completionQueue_, completionQueue_, this);
            
            **doSomeThing();**
            
            
        } else if (PROCESS == status_) {
            new CallData(service_, completionQueue_, sender_);
            
            //
            
            status_ = FINISH;
            responder_.Finish(reply_, Status::OK, this);
        } else {
            GPR_ASSERT(FINISH == status_);
            delete this;
        }
    }

private:
    enum CallStatus {
        CREATE, PROCESS, FINISH
    };
    CallStatus status_;
    
    //
};

Previous: Npm installation depends on package error

Next: Django static deals with picture problems

The problem of using grpc in PHP
recently, while learning grpc, I found that V2ray s API was written in grpc, so I gave it a try. Encountered the following problems when a reply is received after the message is sent, php throws fatalerror <?php require_once __DIR__ . vendor...

Php grpc protobuf

Mar.25,2021
How do I make a remote call without defining a protobuf?
use NodeJS to implement the gateway layer, receive the HTTP request from the front end, and then forward it to the private network for RPC call. However, both the official documentation of gRPC and the Client implementation of the example need to refer ...

Micro-service protobuf grpc

Mar.29,2021
The structure generated by protoc has some strange fields. Will it report an error if it is directly stored in MySQL?
< H1 > question < H1 > Message user is like this message User { int32 uid = 1; string username = 2; string password = 3; } The go code generated by looks like this: type User struct { Uid int32 `protobuf:"va...

Grpc protobuf golang

Apr.01,2021
Push service, will there be a discount on the performance of communication from socket to grpc,?
wrote a distributed push service in golang has multiple connection layers and a topic management service multiple connection layers transmit to topic through socket now I want to change the connection layer to grpc calls I wonder if there will be a d...

Rpc grpc golang

May.22,2021
Does the Dial of golang grpc need Close? in the IM type and micro-service architecture?
problem description in the actual development of golang, whether the Dial, of grpc needs to be closed or not, it can be done in init () if it does not need to be closed. It is better to keep the connection pool long when the connection is closed frequ...

Grpc Micro-Service golang

Jul.16,2021
How to call grpc in flask
-sharp flask route @app.route( test ) def test(): -sharp flask send_grpc() -sharp __main__ def send_grpc(): channel = grpc.insecure_channel( server_host ) client = something_pb2_grpc.SomethingStub(channel=channel) -sharp flask res =...

Python grpc flask

Sep.30,2021
How does php grpc client set the timeout?
grpc-php-client writes log to grpc-golang-server but when you need to write log to php, set it to timeout client: <?php require dirname(__FILE__). vendor autoload.php ; include_once dirname(__FILE__). Apibeatlog ApiBeatClient.php ; include_...

Grpc php

Nov.14,2021
How to convert message generated by grpc/thrift idl file to Java Bean
for example, I m describing a message in grpc s proto file. then use the command to generate the Java Bean file, so do I still want to keep my previous Java Bean? because the Java file generated by grpc contains a large number of grpc framework-re...

Grpc thrift

Dec.08,2021
Protobuf repeated defines an array element. The element may be an object or what about null?
protobuf repeated defines an array element. What if the element may be an object or null? ...

Grpc protobuf

Dec.15,2021
The problem of Protobuf generating go pointer
the proto file I now define is as follows syntax = "proto2"; message Test1 {} message Test2 { required Test1 test1 = 1; } message Test3 { required Test2 test2 = 1; } then I will get a go file with the approximate content type Test...

Pointer grpc protobuf golang

Jan.11,2022
IOS foreground java background, how to use grpc to add permissions to transfer? Demo, who is not authorized by the government, explained only a few words in vagueness.
how to add permissions to iOS frontend, java backend and grpc? there is no official demo with permission, so there is no problem without permission. If you add permission to Android, you can t solve it on iOS. On the Android side, it is done in recei...

Grpc go ios objective-c java

Jul.15,2022

MySQL Query : SELECT * FROM `codeshelper`.`v9_news` WHERE status=99 AND catid='6' ORDER BY rand() LIMIT 5
MySQL Error : Disk full (/tmp/#sql-temptable-64f5-1e47c99-4391c.MAI); waiting for someone to free some space... (errno: 28 "No space left on device")
MySQL Errno : 1021
Message : Disk full (/tmp/#sql-temptable-64f5-1e47c99-4391c.MAI); waiting for someone to free some space... (errno: 28 "No space left on device")
Need Help?