0

iv単純な非同期クライアントとサーバーを作成しましたが、最初に受信した後にクライアントに応答させることができません。サーバーはクライアントから受信した後に応答を返すことができるようですが、クライアントはできません:

クライアントのセッションは次のとおりです。

[mike@mike Public]$ python cl.py 
buf got your stuff
dded callback           ## this is a log  addded  to see if execution got where i wanted

サーバーのログは次のとおりです。

[mike@mike Public]$ python that.py 
buf ehlo localhost

私はある種のピンポン効果を期待していました.1つが送信され、次にもう1つが送信され、次にすすぎが繰り返されます。

クライアントのコードは次のとおりです。

import socket
import fcntl, os, io, time, functools
from tornado import ioloop


class Punk(object):
     def  __init__(self):
         self.loop = ioloop.IOLoop.instance()
         self.address = 'blah.sock'
         self.authkey = "none"
         self.sock  = socket.socket(socket.AF_UNIX)
     def setup(self):

         self.sock.connect(self.address)
         fcntl.fcntl(self.sock, fcntl.F_SETFL, os.O_NONBLOCK)
         self.sock.sendall("ehlo localhost")
         self.fd = self.sock.fileno()
         self.loop.add_handler(self.fd,self.reader,self.loop.READ)
         self.loop.start()

     def reader(self,fd,event):
         result = b""
         if event == self.loop.READ:

             try:
                 while True:
                     servrep = self.sock.recv(1024)
                     if not servrep:
                         break
                     result += servrep
                     self.prnt(result)
                     break
             except Exception as e:
                 print "this %s happend"%e
         return

     def prnt(self,buf):
         print "buf %s"%buf
         tim =  time.time() + 2
         self.loop.instance().add_timeout(tim, self.reply)
         #callbac = functools.partial(self.loop.add_timeout,tim,self.reply)
         #self.loop.add_callback(self.reply)    ### i tried this too
         print "added callback"


     def reply(self):
         self.sock.sendall(" clent got your stuff")

if __name__ == "__main__":
     bob = Punk()
     bob.setup()

ここにサーバーがあります：

import socket
import fcntl, os, io, time, functools
from array import array
from tornado import ioloop 


class Player(object):
     def  __init__(self):
         self.loop = ioloop.IOLoop.instance()
         self.address = 'blah.sock'
         self.authkey = "none"
         self.sock  = socket.socket(socket.AF_UNIX)
     def setup(self):
         self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,1)
         self.sock.bind(self.address)
         fcntl.fcntl(self.sock, fcntl.F_SETFL, os.O_NONBLOCK)
         self.sock.listen(1)
         self.fd = self.sock.fileno()
         self.loop.add_handler(self.fd,self.reader,self.loop.READ)
         self.loop.start()

     def reader(self,fd,event):
         result = b""
         if event == self.loop.READ:
             self.conn, self.addr = self.sock.accept() 
             try:
                 while True:
                     maxrep = self.conn.recv(1024)
                     if not maxrep:
                         break
                     result += maxrep
                     self.prnt(result)
                     break
             except Exception as e:
                 print "this %s happend"%e
         return

     def prnt(self,buf):
         print "buf %s"%buf
         tim = time.time() + 2
         self.loop.instance().add_timeout(tim, self.reply) 
         #callbac = functools.partial(self.loop.add_timeout,tim,self.reply)
         #self.loop.add_callback(callbac)


     def reply(self):
         self.conn.sendall("got your stuff")

if __name__ == "__main__":
     bob = Player()
     bob.setup()
4

1 に答える 1

0

ソケットを非ブロック モードに設定しましたが、接続がない場合に非ブロック状態から受け入れるときにエラーをキャッチしませんでした: ここで:

def reader(self,fd,event):
     result = b""
     if event == self.loop.READ:
         self.conn, self.addr = self.sock.accept()

する必要があります

 def reader(self,fd,event):
     result = b""
     if event == self.loop.READ:
         try:
             self.conn, self.addr = self.sock.accept() # we get stuck here
             self.connl.append(self.conn)
         except Exception as e:
             pass
于 2013-08-04T14:12:37.103 に答える