Autobahn twisted websocket server does not send messages to client unless it receives a message from a client
I'm running an autobahn/twisted python websocket server and I'm having a problem with sending messages to clients. It seems to only sends messages to clients when a client sends it a message. For some reason, If I want to force out messages to connected clients, the message gets stuck in a queue until any client sends me a message. At that point, all the queued messages go out to all clients.
I was able to reproduce this behavior with both python clients and javascript clients against this python autobahn/twisted websocket server.
Can anyone tell me how to properly send a message from the websocket server to all connected clients? My goal is to let clients subscribe to events, then the server just sends them event messages. But for some reason this above behavior isn't letting the server send clients messages unless they first send the server a message.
You can easily reproduce this using the code below: You only need one server and one client to reproduce it. I used two different clients to prove that the issue was with the server.
Autobahn/twisted python websocket server
Regardless of which websocket client I'm using, I'm seeing the same behavior. So clearly the websocket server is queueing messages for some reason.
Server logs, every 5 seconds on the dot it claims to be sending a message.
Python client shows the difference in time between when the server sent the message and when the python client received it. Notice they come in chunks and some have a massive delay.
Javascript client gets them in chunks of 4 only after it sends the server a new message.
Twisted APIs are not threadsafe. With the exception of reactor.callFromThread, you may only call them in the thread the reactor is running in.
Try not using multithreading at all in your Twisted-based program, as a start. I don't see anything in your code that calls for multiple threads.
- AttributeError: install_layout when attempting to install a package in a virtual environment
- Python list comprehension - want to avoid repeated evaluation
- Hash algorithm for dynamic growing/streaming data?
- matplotlib - making labels for violin plots
- Python How to I check if last element has been reached in iterator tool chain?
- Polars and the Lazy API: How to drop columns that contain only null values?
- Why are my Mean, Var, and Std outputs from NumPy different from what the online grader expects?
- Correlation dataframe convertion from results from pl.corr
- Polars DataFrame transformation
- Discord rate limiting while only sending 1 request per minute
- Check if column contains (/,-,_, *or~) and split in another column - Pandas
- How to draw a rectangle at (x,y) in a PyQt GraphicsView?
- how to calculate correlation between ten columns with polars
- How to set class attribute with await in __init__
- Detect hindi encoding, response received from Facebook API in Python
- Is it possible to write a horizontal if statement with a multi-line body?
- Max length of items in list
- Cannot subclass multiprocessing Queue in Python 3.5
- How can I get notified of updates to Python packages in a unified way?
- Using python AST to traverse code and extract return statements
- merge groups of columns in a polars dataframe to single columns
- Group Pandas DataFrame by Continuous Date Ranges
- Flask login @login_required not working
- Odoo: one2many and many2one? KeyError:'___'
- merge some columns in a Polars dataframe and duplicate the others
- Python: Create table from string mixed with separators using FOR loops
- How do I type hint a method with the type of the enclosing class?
- How can I verify an emails DKIM signature in Python?
- Writing a class that accepts a callback in Python?
- Python Paramiko channel.exec_command not returning output intermittently