def open(self):
# ?????path
self.file_path = self.get_argument('file_path', '')
MonitorHandler.clients.append(self)
thread = MyThread(target=file_monitor, args=('%s.log' % self.file_path, self))
MonitorHandler.threads.append(thread)
self.stream.set_nodelay(True)
try:
for t in MonitorHandler.threads:
if t.is_alive():
continue
t.setDaemon(True)
t.start()
except WebSocketClosedError:
client_index = MonitorHandler.clients.index(self)
MonitorHandler.threads[client_index].stop()
MonitorHandler.clients.remove(self)
MonitorHandler.threads.remove(MonitorHandler.threads[client_index])
logger.debug("Websocket: Monitor client num: %s, thread num: %s" % (len(MonitorHandler.clients),
len(MonitorHandler.threads)))
python类WebSocketClosedError()的实例源码
def open(self):
# ?????path
self.file_path = self.get_argument('file_path', '')
MonitorHandler.clients.append(self)
thread = MyThread(target=file_monitor, args=('%s.log' % self.file_path, self))
MonitorHandler.threads.append(thread)
self.stream.set_nodelay(True)
try:
for t in MonitorHandler.threads:
if t.is_alive():
continue
t.setDaemon(True)
t.start()
except WebSocketClosedError:
client_index = MonitorHandler.clients.index(self)
MonitorHandler.threads[client_index].stop()
MonitorHandler.clients.remove(self)
MonitorHandler.threads.remove(MonitorHandler.threads[client_index])
logger.debug("Websocket: Monitor client num: %s, thread num: %s" % (len(MonitorHandler.clients),
len(MonitorHandler.threads)))
def _deliver(cls, message, upn="AUTHENTICATED", session=None):
"""
Writes the given *message* (string) to all users matching *upn* using
the write_message() function. If *upn* is not provided or is
"AUTHENTICATED", will send the *message* to all users.
Alternatively a *session* ID may be specified instead of a *upn*. This
is useful when more than one user shares a UPN (i.e. ANONYMOUS).
"""
#print 'deliver message',message
logging.debug("_deliver(%s, upn=%s, session=%s)" %
(message, upn, session))
for instance in cls.instances:
try: # Only send to users that have authenticated
user = instance.current_user
except (WebSocketClosedError, AttributeError):
continue
if session and user and user.get('session', None) == session:
instance.write_message(message)
elif upn == "AUTHENTICATED":
instance.write_message(message)
elif user and upn == user.get('upn', None):
instance.write_message(message)
def open(self):
# ?????path
self.file_path = self.get_argument('file_path', '')
MonitorHandler.clients.append(self)
thread = MyThread(target=file_monitor, args=('%s.log' % self.file_path, self))
MonitorHandler.threads.append(thread)
self.stream.set_nodelay(True)
try:
for t in MonitorHandler.threads:
if t.is_alive():
continue
t.setDaemon(True)
t.start()
except WebSocketClosedError:
client_index = MonitorHandler.clients.index(self)
MonitorHandler.threads[client_index].stop()
MonitorHandler.clients.remove(self)
MonitorHandler.threads.remove(MonitorHandler.threads[client_index])
logger.debug("Websocket: Monitor client num: %s, thread num: %s" % (len(MonitorHandler.clients),
len(MonitorHandler.threads)))
def send_message(self, action, **data):
"""Sends the message to the connected client
"""
message = {
"action": action,
"data": data
}
try:
self.write_message(json.dumps(message))
except WebSocketClosedError:
logger.warning("WS_CLOSED", "Could Not send Message: " + json.dumps(message))
# Send Websocket Closed Error to Paired Opponent
self.send_pair_message(action="pair-closed")
self.close()
def run(self):
try:
super(MyThread, self).run()
except WebSocketClosedError:
pass
def open(self):
# ?????path
self.file_path = self.get_argument('file_path', '')
MonitorHandler.clients.append(self)
thread = MyThread(target=file_monitor, args=('%s.log' % self.file_path, self))
MonitorHandler.threads.append(thread)
self.stream.set_nodelay(True)
try:
for t in MonitorHandler.threads:
if t.is_alive():
continue
t.setDaemon(True)
t.start()
except WebSocketClosedError:
client_index = MonitorHandler.clients.index(self)
MonitorHandler.threads[client_index].stop()
MonitorHandler.clients.remove(self)
MonitorHandler.threads.remove(MonitorHandler.threads[client_index])
logger.debug("Websocket: Monitor client num: %s, thread num: %s" % (len(MonitorHandler.clients),
len(MonitorHandler.threads)))
def run(self):
try:
super(MyThread, self).run()
except WebSocketClosedError:
pass
def run(self):
try:
super(MyThread, self).run()
except WebSocketClosedError:
pass
def send_to_the_client(self, data):
try:
self.write_message(data)
except websocket.WebSocketClosedError as e:
self.on_close()
def callback(self, channel, method, header, body):
machine = method.routing_key.split(".")[0]
data = json.loads(body.decode("utf-8"))
data['machine'] = machine
try:
self.write_message(data)
except websocket.WebSocketClosedError as e:
self.on_close()
def run(self):
try:
super(MyThread, self).run()
except WebSocketClosedError:
pass
def ka(self):
# print "%d: Keepalive: %s" % (time.time(), str(self))
try:
self.write_message(self.KA)
tornado.ioloop.IOLoop.instance().add_timeout(datetime.timedelta(seconds=2), self.ka)
except websocket.WebSocketClosedError:
pass
def broadcast(self, message, channel, sender):
subscribers = self.get_subscribers(channel)
for subscriber in subscribers:
if subscriber != sender:
try:
subscriber.write_message(message)
except WebSocketClosedError:
self.remove_subscriber(channel, subscriber)
