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.
- WSGIServerException: [Errno 8] nodename nor servname provided, or not known
- Python/Flask Login form throws 500 error on IIS
- Matplotlib plt.show() isn't showing graph
- How to avoid duplicate processing in python API server?
- Extract points/coordinates from a polygon in Shapely
- How do I detect collision in pygame?
- Typehint a method that returns new instance using a superclass classmethod
- How to process requests from multiiple users using ML model and FastAPI?
- How can I clear the interpreter console?
- What are the reasons for the differences in output results when using the groupby function in the Python pandas package?
- How to antialias picture to get rid of the jerkiness in the image
- Is there any difference between list(array) and array.tolist() in Python?
- How to move x-axis on top of the plot in plotnine?
- Pulling Zillow Rent Data from Zillow API
- Safest way to incrementally append to a file?
- Unable to install mysqlclient package on EC2 instance
- FastAPI - How to get app instance inside a router?
- SQLAlchemy: engine, connection and session difference
- Generating binary arrays with alternating values based on change indices in NumPy
- How can i solve this error: ValueError: The feature names should match those that were passed
- 'super' object has no attribute '__sklearn_tags__'
- Python: How to copy all attibutes from base class to derived one
- mitm proxy is closed, but the port is still occupied
- How to find pg_config path
- Why does "pip install" inside Python raise a SyntaxError?
- Plotting a matplotlib pie chart using 2 columns
- ImportError: No module named langchain.llms
- How do I disable the security certificate check in Python requests
- How can I import Psycopg2 into a Lambda Function on AWS?
- Django built in Logout view `Method Not Allowed (GET): /users/logout/`