1

他のpython（OpenCVを使用しているためCPython）からメッセージを受信するJython（実際にはmonkeyrunner）プログラムを作成しようとしています

最初に、チャット プログラムのサンプル (サーバー側) を実装しようとしましたが、問題が発生しました。

この例では select に Blocking-socket を使用していますが、Jython select はそれをサポートできません。

そのため、ソケットの設定時に「server_socket.setblocking(0)」というコードを入れましたが、何も変わりませんでした。

また、「from select import cpython_compoatible_select as select」を試してみましたが、Attribute error, 'function' object has no attribute 'select' が発生します。

以下は私のコードです

    # coding: iso-8859-1
    import socket,select
    #Function to broadcast chat messages to all connected clients
    def broadcast_data (sock, message):
        #Do not send the message to master socket and the client who has send us the message
        for socket in CONNECTION_LIST:
            if socket != server_socket and socket != sock :
                try :
                    socket.send(message)
                except :
                    # broken socket connection may be, chat client pressed ctrl+c for example
                    socket.close()
                    CONNECTION_LIST.remove(socket)

    if __name__ == "__main__":

        # List to keep track of socket descriptors
        CONNECTION_LIST = []
        RECV_BUFFER = 4096 # Advisable to keep it as an exponent of 2
        PORT = 5000

        server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # this has no effect, why ?
        #JYTHON never supports blocking-mode socket so make it unblock
        server_socket.setblocking(0)  
        server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        server_socket.bind(("0.0.0.0", PORT))
        server_socket.listen(10)

        # Add server socket to the list of readable connections
        CONNECTION_LIST.append(server_socket)

        print "Chat server started on port " + str(PORT)

        while 1:
            # Get the list sockets which are ready to be read through select
            #JYTHON never supports blocking-mode socket so make it unblock
            server_socket.setblocking(0)          
            read_sockets,write_sockets,error_sockets = select.select(CONNECTION_LIST,[],[])

            for sock in read_sockets:
                #New connection
                if sock == server_socket:
                    # Handle the case in which there is a new connection recieved through server_socket
                    #JYTHON never supports blocking-mode socket so make it unblock
                    server_socket.setblocking(0)                        
                    sockfd, addr = server_socket.accept()

                    CONNECTION_LIST.append(sockfd)
                    #print "Client (%s, %s) connected" % addr

                    broadcast_data(sockfd, "[%s:%s] entered room\n" % addr)

                #Some incoming message from a client
                else:
                    # Data recieved from client, process it
                    try:
                        #In Windows, sometimes when a TCP program closes abruptly,
                        # a "Connection reset by peer" exception will be thrown
                        data = sock.recv(RECV_BUFFER)
                        if data:
                            print data
                            broadcast_data(sock, "\r" + '<' + str(sock.getpeername()) + '> ' + data)                

                    except:
                        broadcast_data(sock, "Client (%s, %s) is offline" % addr)
                        print "Client (%s, %s) is offline" % addr
                        sock.close()
                        CONNECTION_LIST.remove(sock)
                        continue

        server_socket.close()
        #see http://www.binarytides.com/code-chat-application-server-client-sockets-python/

そして私のエラーメッセージ

C:\NVPACK\android-sdk-windows\tools\lib>monkeyrunnerUTF chatserver.py
Chat server started on port 5000
130815 17:06:17.418:S [MainThread] [com.android.monkeyrunner.MonkeyRunnerOptions
] Script terminated due to an exception
130815 17:06:17.418:S [MainThread] [com.android.monkeyrunner.MonkeyRunnerOptions
]Traceback (most recent call last):
  File "C:\NVPACK\android-sdk-windows\tools\chatserver.py", line 41, in <module>

    read_sockets,write_sockets,error_sockets = select.select(CONNECTION_LIST,[],
[])
  File "C:\NVPACK\android-sdk-windows\tools\lib\jython-standalone-2.5.3.jar\Lib\
select.py", line 225, in native_select
  File "C:\NVPACK\android-sdk-windows\tools\lib\jython-standalone-2.5.3.jar\Lib\
select.py", line 106, in register
select.error: (20000, 'socket must be in non-blocking mode')

前もって感謝します ：）

4

1 に答える 1