protobuf_socket_rpc.

Implementazione Giava e Python Protobuf RPC utilizzando prese TCP / IP
Scarica ora

protobuf_socket_rpc. Classifica e riepilogo

Annuncio pubblicitario

  • Rating:
  • Licenza:
  • MIT/X Consortium Lic...
  • Prezzo:
  • FREE
  • Nome editore:
  • Martin Norbury
  • Sito web dell'editore:
  • http://code.google.com/u/martin.norbury/

protobuf_socket_rpc. Tag


protobuf_socket_rpc. Descrizione

Implementazione di Giava e Python Protobuf RPC utilizzando prese TCP / IP protobuf_socket_rpc è un'implementazione Python del buffer del protocollo di Google Socket-RPC.USAGE: per un servizio MyService con un metodo Mymethod che prende un messaggio MyRequest ProTOBUF e restituisce un messaggio MyResponse Protobuf Message.javasample Server Codice di utilizzo del lato server: // Start ServersCheRServerPCServer SOCKETRPCServer = Nuovo Socketrpcserver (ServerPort, Exors.NewfixedThreadpool (ThreadPoolsize)); SOCKETRETRPCServer.registerservice (New MyServiceImpl ()); SOCKETRPCServer.Run (); Esempio di client Client Codice di utilizzo del lato: // Creare ChannelsocketrpcChannel SOCKETRPCCHANNEL = Nuovo SocketrpcChannel (host, porto); SOCKETRPCCONTROLL rpcController = SOCKETRPCCHANNEL.NEWRPCCONTROLLER (); // Call ServicemyService MyService = MyService.newstub (SochetrpcChannel); myservice.mymethod (rpcController, MyRequest, New RPCCallback () {Public Void Run (MyResponse Myresponse) {Ricevy.out.Println ("ricevuto. Risposta: "+ myresponse);}}); // Verifica successif (rpccontroller.failed ()) {system.err.println (string.format ("RPC non riuscito% s:% s", rpccontroller.ercorren (), rpccontroller.errorread ()));} Pythonsample server lato Codice utilizzo: // Start Serververver = proobuf.server.socketrpcserver (porta) server.registerserservice (MyServiceImpl ()) server.Run () Cliente di esempio Codice di utilizzo del lato: // Definisci callbackClass Callback: DEF RUN (Self, Risposta): Stampa "Risposta ricevuta:% s"% risposta // crea canalechannel = protobuf.channel.socketrpcchannel (hostname, porto) controller = canale.newcontroller () // Call Serviceservice = MyService_Stub (Channel) Service.Mymethod (controller, richiesta, callback ( )) // Controllare il controller successif successive.Failed (): Stampa "RPC Failed% s:% s"% (controller.error, controller.reason)


protobuf_socket_rpc. Software correlato