 | protobuf_socket_rpc.Java e Python ProtoBuf RCP de implementação usando soquetes TCP / IP |
| Baixe Agora | |
protobuf_socket_rpc. Classificação e resumo
Propaganda
- Licença:
- MIT/X Consortium Lic...
- Preço:
- FREE
- Nome do editor:
- Martin Norbury
- Site do editor:
- http://code.google.com/u/martin.norbury/
protobuf_socket_rpc. Tag
protobuf_socket_rpc. Descrição
Implementação Java e Python ProtoBuf RPC usando soquetes TCP / IP ProtoBuf_Socket_RPC é uma implementação Python do Soquete do Buffer do Protocolo do Google: Para um serviço MyService com um método MyMethod que leva em uma mensagem MyRequest ProtoBuf e retorna um MyResponse ProtoBuf Message.Javasample Servidor Side Usage Código: // Iniciar ServersocketrPCServer SocketrPCServer = Novo SocketrPCServer (Serverport, Executores.NewfixedthreadPool (ThreadPoolsize)); Socketrpcserver.Registerservice (novo myserviceimpl ()); socketrpcserver.run (); amostra Código do uso do lado do cliente: // Create ChannelocketrPcChannel SocketrPcChannel = New SocketrpcChannel (host, porta); Socketrpccoller rpccontroller = socketrpcchannel.newrpccontroller (); // chamada de chamada manservice myservice = myservice.newstub (socketrpcchannel); myservice.mmethod (rpccontroller, myrequest, novo rpccallback () {public void run (myResponse.out.println ("recebido Resposta: "+ MyResponse);}}); // Verifique successif (rpccontroller.failed ()) {system.errintln (string.errintln (string.format ("RPC falhou% s:% s", rpccontroller.reason (), RPCController.ErrArtext ());} Lado do servidor Pythonsample Código de uso: // Iniciar ServerServer = ProtoBuf.Server.socketrpcserver (porta) Server.Registerservice (myserviceimpl () Server.run () Amostra Código do uso do lado do cliente: // Definir a chamada CallbackClass: Def Run (auto, resposta): Imprimir "Resposta recebida:% s"% Resposta // Criar canalChannel = ProtoBuf.Channel.SocketrPcChannel (nome do host, porta) controlador = Channel.NewController () // Call ServiceService = MyService_stub (Channel) Service.mmethod (Controlador, solicitação, retorno de chamada )) // Verifique o controlador successif.failed (): Imprimir "RPC Failed% S:% s"% (controller.Error, Controller.Reason)
protobuf_socket_rpc. Software Relacionado
