Analyser des exemples d'utilisation de TCP Interactive Thrift

Apache Thrift est un framework efficace implémenté par Facebook qui prend en charge l'invocation de services à distance dans plusieurs langages de programmation.

• Installez thrift Téléchargez depuis le site officiel et installez-le selon ./configure, make, make install Pour les autres systèmes, veuillez vous référer au site officiel http://thrift.apache. .org/docs/install/

• Définissez le fichier d'épargne, qui est équivalent à la définition de l'interface des deux parties de communication

  bool Boolean, one byte * i8 (byte) Signed 8-bit integer * i16 Signed 16-bit integer *
   i32 Signed 32-bit integer *
   i64 Signed 64-bit integer * 
  double 64-bit floating point value * string String * binary Blob (byte array) 
  * map<t1,t2> Map from one type to another 
  * list<t1> Ordered list of one type 
  * set<t1> Set of unique elements of one type

.

• Utiliser thrift pour générer des informations sur thrift Le code défini correspond à différents langages. J'utilise principalement python, mais il peut également utiliser d'autres c++ et java. La commande est thrift --gen filename>

• Lors de l'écriture du serveur et du client, le serveur doit considérer le non-blocage et le multi-processus pour assurer un service normal. La classe générée par thrift doit être appelée pour correspondre aux données définies. taper.

  def init_handler():    """ sub-process init handler """
      signal.signal(signal.SIGINT, signal.SIG_DFL)
      signal.signal(signal.SIGTERM, signal.SIG_DFL)
      signal.signal(signal.SIGHUP, signal.SIG_DFL)
      signal.signal(signal.SIGUSR1, debug)def main():    """ The main entrance """
      port = sys.argv[1]
      signal.signal(signal.SIGINT, exit_signal_handler)
      signal.signal(signal.SIGTERM, exit_signal_handler)
      signal.signal(signal.SIGHUP, exit_signal_handler)
      signal.signal(signal.SIGUSR1, debug)
      gc.set_threshold(20000, 10, 10)
      handler = MaitreyaHandler()
      processor = Maitreya.Processor(handler)
      transport = TSocket.TServerSocket(port=port)
      tfactory = TTransport.TBufferedTransportFactory()
      pfactory = TBinaryProtocol.TBinaryProtocolFactory()    # server = TProcessPoolServer(processor, transport, tfactory, pfactory)
      server = TGeventServer.TGeventProcessPoolServer(processor, transport, tfactory, pfactory)
      server.setNumWorkers(WORKER_NUM)
      server.setPostForkCallback(init_handler)    print "server started..."
      server.serve()

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!