是否有爲python實現的WebSocket客戶端？

Question

我發現這個項目：http://code.google.com/p/standalonewebsocketserver/爲websocket服務器，但我需要在python中實現一個websocket客戶端，更確切地說，我需要從我的websocket服務器中的xmpp接收一些命令。

Answer 1

1. 看看http://code.google.com/p/pywebsocket/下的echo客戶端這是一個Google項目。
2. 在github上的一個好的搜索是：https://github.com/search?type=Everything&language=python&q=websocket&repo=&langOverride=&x=14&y=29&start_value=1它返回客戶端和服務器。
3. Bret Taylor還在Tornado（Python）上實現了web套接字。他的博客文章位於：Web Sockets in Tornado，客戶端實施API顯示在客戶端支持部分的tornado.websocket。

Answer 2

的web2py具有comet_messaging.py，它採用了龍捲風的WebSockets在這裏看看一個例子：http://vimeo.com/18399381這裏VIMEO。 com/18232653

Answer 3

由於我最近在這方面做了一些研究（1月，'12），最有前途的客戶實際上是：WebSocket for Python。它支持正常的插座，你可以這樣調用：

ws = EchoClient('http://localhost:9000/ws') 

的client可以Threaded或Tornado項目基於IOLoop。這將允許您創建一個多併發連接客戶端。如果你想運行壓力測試，這很有用。

客戶端還公開onmessage,opened和closed方法。 （WebSocket風格）。

Answer 4

Autobahn爲Python提供了一個很好的websocket客戶端實現以及一些很好的例子。我使用Tornado WebSocket服務器測試了以下內容，並且工作正常。

from twisted.internet import reactor 
from autobahn.websocket import WebSocketClientFactory, WebSocketClientProtocol, connectWS 


class EchoClientProtocol(WebSocketClientProtocol): 

    def sendHello(self): 
     self.sendMessage("Hello, world!") 

    def onOpen(self): 
     self.sendHello() 

    def onMessage(self, msg, binary): 
     print "Got echo: " + msg 
     reactor.callLater(1, self.sendHello) 


if __name__ == '__main__': 

    factory = WebSocketClientFactory("ws://localhost:9000") 
    factory.protocol = EchoClientProtocol 
    connectWS(factory) 
    reactor.run() 

Answer 5

http://pypi.python.org/pypi/websocket-client/

可笑容易使用。

sudo pip install websocket-client 

樣品的客戶端代碼：

#!/usr/bin/python 

from websocket import create_connection 
ws = create_connection("ws://localhost:8080/websocket") 
print "Sending 'Hello, World'..." 
ws.send("Hello, World") 
print "Sent" 
print "Reeiving..." 
result = ws.recv() 
print "Received '%s'" % result 
ws.close() 

樣的服務器代碼：

#!/usr/bin/python 
import websocket 
import thread 
import time 

def on_message(ws, message): 
    print message 

def on_error(ws, error): 
    print error 

def on_close(ws): 
    print "### closed ###" 

def on_open(ws): 
    def run(*args): 
     for i in range(30000): 
      time.sleep(1) 
      ws.send("Hello %d" % i) 
     time.sleep(1) 
     ws.close() 
     print "thread terminating..." 
    thread.start_new_thread(run,()) 


if __name__ == "__main__": 
    websocket.enableTrace(True) 
    ws = websocket.WebSocketApp("ws://echo.websocket.org/", 
           on_message = on_message, 
           on_error = on_error, 
           on_close = on_close) 
    ws.on_open = on_open 

    ws.run_forever()