1
0
mirror of https://github.com/actix/examples synced 2024-11-23 14:31:07 +01:00
examples/websockets/chat
2024-08-07 02:04:57 +01:00
..
src chore: reword module docs for clarity 2024-07-21 06:25:56 -04:00
static chore: update actix-ws to v0.3 2024-07-20 07:55:03 +01:00
Cargo.toml remove unneeded dependencies 2023-07-18 17:42:33 +01:00
client.py Fix Websockets/Chat: Prefixing Username to Messages Interferes with Server Commands (#634) 2023-09-10 20:22:35 +01:00
README.md chore: fmt 2024-08-07 02:04:57 +01:00
requirements.txt fix websockets chat example (#591) 2022-12-11 11:30:31 +00:00

Websocket chat example

This is a multi-threaded chat server example.

Fancy shiny features:

  • Browser-based WebSocket client served from static html+js
  • Chat server runs in separate thread
  • Tcp listener runs in separate thread
  • Application state is shared with the websocket server and a resource at /count/
  • Uses actors for improved readability of code in the server.rs implementation

Server

  1. Chat server listens for incoming tcp connections. Server can access several types of message:
  • /list - list all available rooms
  • /join name - join room, if room does not exist, create new one
  • /name name - set session name
  • some message - just string, send message to all peers in same room
  • client has to respond to heartbeat Ping messages, if server does not receive a heartbeat 'Pong' message for 10 seconds connection gets dropped
  1. http://localhost:8080/count/ is a non-websocket endpoint and will affect and display state.

To start server use the following

cd websockets/chat
cargo run --bin websocket-chat-server

WebSocket Browser Client

Python Client using aiohttp

  • Client connects to server. Reads input from stdin and sends to server.
  • Create a venv environment python3 -m venv venv.
  • Launch venv environment source ./venv/bin/activate.
  • Fetch the needed python libraries pip3 install -r requirements.txt.
  • Then start client as ./client.py.