Calculer Girl
  1. Calculer Girl
  3. Apache Thrift Python-Java ‘Connexion refusée’
Intereting Posts
Erreur d’installation de uwsgi dans virtualenv Quelle est la meilleure façon d’installer Mod_jk sur Linux pour exécuter apache devant tomcat En quoi ChildWindowFromPointEx et ChildWindowFromPoint sont-ils différents du paramètre “flags”? Apache2 – autorise les utilisateurs contre un emplacement utilisant BasicAuth mais UNIQUEMENT pour les utilisateurs extérieurs au sous-réseau local Y a-t-il un équivalent d’Ansible à “failed_when” pour réussir Extraction de plusieurs lignes avec recouvrement à l’aide de awk Associer des fichiers avec une extension spécifique à ma propre application en Python Voir trop de lsof ne peut pas identifier le protocole Comment combiner les entrées de deux contrôleurs de jeu dans un seul contrôleur “virtuel”? Le script Python utilise la boucle while pour continuer à mettre à jour les scripts de travail et à traiter plusieurs fois les tâches dans la queue Le script bash contient du code perl – et s’exécute sur Python Unix “wrap” filter Obtenir Windows pour démarrer R en mode batch en utilisant la commande Démarrer Django – dans le modèle, created_at est un horodatage UNIX Comment puis-je vérifier le transfert de données sur une interface réseau en python?

Apache Thrift Python-Java ‘Connexion refusée’

J’ai récemment essayé de connecter Python à Java en utilisant Thrift.

J’ai écrit un serveur sur Python (PyPy). J’ai également écrit un client de référence qui fonctionne.

Ensuite, j’ai écrit un client Java qui ne produit qu’une exception ‘Connexion refusée’.

Qu’est-ce qui ne va pas avec ça? (Récemment, j’ai également trouvé un problème fermé avec ce problème https://issues.apache.org/jira/browse/THRIFT-1888 )

PS Version Thrift 0.9 utilisée, PyPy 2.0 beta 2, Java 1.7.0_11

test.thrift 

namespace java com.test namespace python test service TestPing { void ping() }

Code du serveur Python 

 class TestPingHandler: def ping(self): pass handler = TestPingHandler() processor = TestPing.Processor(handler) transport = TSocket.TServerSocket(port=9091) tfactory = TTransport.TBufferedTransportFactory() pfactory = TBinaryProtocol.TBinaryProtocolFactory() server = TServer.TThreadedServer(processor, transport, tfactory, pfactory) print 'Starting the server...' server.serve() print 'done.'

Code client Java 

 TTransport transport; transport = new TSocket("localhost", 9091); transport.open(); TProtocol protocol = new TBinaryProtocol(transport); client = new TestPing.Client(protocol); client.ping();

Code client Python de référence 

 transport = TSocket.TSocket('localhost', 9091) transport = TTransport.TBufferedTransport(transport) protocol = TBinaryProtocol.TBinaryProtocol(transport) client = TestPing.Client(protocol) transport.open() client.ping() transport.close()

J’ai eu le même problème. Remplacer “localhost” par l’ip corrigé.

La raison était: Python utilisait TCPV6, où Java utilisait TCP.

Python: transport = TSocket.TServerSocket(host="127.0.0.1", port = 9091)

Java: transport = new TSocket("127.0.0.1", 9091); 

 transport = new TSocket("localhost", 9091); TProtocol protocol = new TBinaryProtocol(transport); transport.open(); This should work...