\u4f5c\u4e3a\u4e00\u4e2a\u5927\u4e09\u7684\u8ba1\u7b97\u673a\u79d1\u5b66\u5b66\u751f，\u6211\u6df1\u523b\u4f53\u9a8c\u5230\u4e86\u5b9e\u65f6\u901a\u4fe1\u5982\u4f55\u5851\u9020\u73b0\u4ee3 Web \u5e94\u7528\u7684\u7528\u6237\u4f53\u9a8c\u3002\u65e0\u8bba\u662f\u5728\u7ebf\u804a\u5929\u3001\u534f\u540c\u7f16\u8f91\u8fd8\u662f\u5b9e\u65f6\u76d1\u63a7，\u540e\u7aef\u6846\u67b6\u7684\u5b9e\u65f6\u901a\u4fe1\u80fd\u529b\u51b3\u5b9a\u4e86\u4ea7\u54c1\u8d28\u91cf\u7684\u4e0a\u9650\u3002\u4eca\u5929，\u6211\u60f3\u4ece\u4e00\u4e2a\u5341\u5e74\u8001\u7f16\u8f91\u548c\u5341\u5e74\u8001\u5f00\u53d1\u8005\u7684\u89d2\u5ea6，\u57fa\u4e8e\u771f\u5b9e\u7684\u5f00\u53d1\u6848\u4f8b，\u7cfb\u7edf\u6027\u5730\u63a2\u8ba8\u5b9e\u65f6 Web \u901a\u4fe1\u7684\u6280\u672f\u5b9e\u73b0\u548c\u67b6\u6784\u6f14\u8fdb\u3002<\/p>\n
\u9879\u76ee\u4fe1\u606f 🚀 Hyperlane \u6846\u67b6: GitHub \u4ed3\u5e93 📧 \u4f5c\u8005\u8054\u7cfb: root@ltpp.vip 📖 \u5b98\u65b9\u6587\u6863: \u6587\u6863\u5730\u5740<\/p>\n
\u4f20\u7edf\u7684 Web \u5e94\u7528\u4ee5\u8bf7\u6c42-\u54cd\u5e94\u4e3a\u4e2d\u5fc3，\u96be\u4ee5\u6ee1\u8db3\u9ad8\u5e76\u53d1\u3001\u4f4e\u5ef6\u8fdf\u7684\u5b9e\u65f6\u573a\u666f\u9700\u6c42\u3002WebSocket \u548c SSE（Server-Sent Events）\u5df2\u7ecf\u6210\u4e3a\u73b0\u4ee3 Web \u5b9e\u65f6\u901a\u4fe1\u7684\u4e3b\u6d41\u89e3\u51b3\u65b9\u6848\u3002<\/p>\n
\u8fd9\u4e2a Rust \u6846\u67b6\u63d0\u4f9b\u4e86\u539f\u751f\u7684 WebSocket \u652f\u6301\u3002\u534f\u8bae\u5347\u7ea7\u3001\u6d88\u606f\u5904\u7406\u3001\u8fde\u63a5\u7ba1\u7406\u7b49\u5168\u90e8\u81ea\u52a8\u5316，\u5927\u5927\u7b80\u5316\u4e86\u5f00\u53d1\u5de5\u4f5c\u3002<\/p>\n
use hyperlane::*;
\nuse hyperlane_macros::*;<\/p>\n
\/\/ WebSocket\u8fde\u63a5\u5904\u7406
\n#[ws]
\n#[get]
\nasync fn ws_route(ctx: Context) {
\n \/\/ \u83b7\u53d6WebSocket\u63e1\u624b\u5bc6\u94a5
\n let key: String = ctx.get_request_header(SEC_WEBSOCKET_KEY).await.unwrap();<\/p>\n
\/\/ \u83b7\u53d6\u8bf7\u6c42\u4f53
\n let request_body: Vec<u8> = ctx.get_request_body().await;<\/p>\n
\/\/ \u53d1\u9001\u63e1\u624b\u54cd\u5e94
\n let _ = ctx.set_response_body(key).await.send_body().await;<\/p>\n
\/\/ \u53d1\u9001\u8bf7\u6c42\u4f53\u56de\u663e
\n let _ = ctx.set_response_body(request_body).await.send_body().await;
\n}<\/p>\n
\/\/ WebSocket\u8fde\u63a5\u5efa\u7acb\u56de\u8c03
\nasync fn on_ws_connected(ctx: Context) {
\n let _ = ctx.set_response_body("connected").await.send_body().await;
\n}<\/p>\n
\/\/ WebSocket\u5347\u7ea7\u524d\u7684\u4e2d\u95f4\u4ef6
\nasync fn pre_ws_upgrade(ctx: Context) {
\n \/\/ \u9a8c\u8bc1\u7528\u6237\u8eab\u4efd
\n let token = ctx.get_request_header("authorization").await;
\n if let Some(token) = token {
\n if validate_token(&token).await {
\n println!("WebSocket connection authorized");
\n } else {
\n ctx.set_response_status_code(401).await;
\n return;
\n }
\n }<\/p>\n
\/\/ \u8bbe\u7f6e\u8fde\u63a5\u5143\u6570\u636e
\n ctx.set_metadata("connection_time", std::time::Instant::now()).await;
\n}<\/p>\n
#[tokio::main]
\nasync fn main() {
\n let server: Server = Server::new();
\n server.host("0.0.0.0").await;
\n server.port(60000).await;<\/p>\n
\/\/ WebSocket\u914d\u7f6e
\n server.ws_buffer_size(4096).await;
\n server.on_ws_connected(on_ws_connected).await;
\n server.pre_ws_upgrade(pre_ws_upgrade).await;<\/p>\n
\/\/ \u8def\u7531\u914d\u7f6e
\n server.route("\/ws", ws_route).await;<\/p>\n
server.run().await.unwrap();
\n}<\/p>\n
SSE \u975e\u5e38\u9002\u5408\u5355\u5411\u4e8b\u4ef6\u6d41\u63a8\u9001\u3002\u8fd9\u4e2a\u6846\u67b6\u7684 API \u6781\u5176\u7b80\u6d01：<\/p>\n
use hyperlane::*;
\nuse hyperlane_macros::*;
\nuse std::time::Duration;<\/p>\n
\/\/ SSE\u9884\u94a9\u5b50：\u8bbe\u7f6e\u54cd\u5e94\u5934
\n#[post]
\nasync fn sse_pre_hook(ctx: Context) {
\n let _ = ctx
\n .set_response_header(CONTENT_TYPE, TEXT_EVENT_STREAM)
\n .await
\n .set_response_status_code(200)
\n .await
\n .send()
\n .await;
\n}<\/p>\n
\/\/ SSE\u540e\u94a9\u5b50：\u6e05\u7406\u8d44\u6e90
\nasync fn sse_post_hook(ctx: Context) {
\n let _ = ctx.closed().await;
\n}<\/p>\n
\/\/ SSE\u4e8b\u4ef6\u6d41
\n#[pre_hook(sse_pre_hook)]
\n#[post_hook(sse_post_hook)]
\nasync fn sse_route(ctx: Context) {
\n \/\/ \u53d1\u900110\u4e2a\u4e8b\u4ef6，\u6bcf\u4e2a\u95f4\u96941\u79d2
\n for i in 0..10 {
\n let event_data = format!("data:{}{}", i, HTTP_DOUBLE_BR);
\n let _ = ctx
\n .set_response_body(event_data)
\n .await
\n .send_body()
\n .await;<\/p>\n
tokio::time::sleep(Duration::from_secs(1)).await;
\n }
\n}<\/p>\n
\/\/ \u5b9e\u65f6\u6570\u636e\u63a8\u9001
\nasync fn real_time_data(ctx: Context) {
\n \/\/ \u8bbe\u7f6eSSE\u54cd\u5e94\u5934
\n ctx.set_response_header(CONTENT_TYPE, TEXT_EVENT_STREAM).await;
\n ctx.set_response_status_code(200).await;
\n ctx.send().await.unwrap();<\/p>\n
\/\/ \u6301\u7eed\u63a8\u9001\u6570\u636e
\n let mut counter = 0;
\n loop {
\n let data = serde_json::json!({
\n "timestamp": chrono::Utc::now().to_rfc3339(),
\n "counter": counter,
\n "message": format!("Event {}", counter)
\n });<\/p>\n
let event = format!("data:{}{}", data, HTTP_DOUBLE_BR);
\n let _ = ctx.set_response_body(event).await.send_body().await;<\/p>\n
counter += 1;
\n tokio::time::sleep(Duration::from_millis(100)).await;
\n }
\n}<\/p>\n
\u8fd9\u4e2a\u6846\u67b6\u57fa\u4e8e Tokio \u5f02\u6b65\u8fd0\u884c\u65f6\u6784\u5efa，\u652f\u6301\u9ad8\u5e76\u53d1\u7684\u6d88\u606f\u5e7f\u64ad\u548c\u5206\u53d1\u3002\u65e0\u8bba\u662f\u7fa4\u804a\u3001\u534f\u540c\u7f16\u8f91\u8fd8\u662f\u5b9e\u65f6\u76d1\u63a7，\u5b9e\u73b0\u90fd\u53d8\u5f97\u7b80\u5355\u76f4\u63a5\u3002<\/p>\n
use hyperlane::*;
\nuse hyperlane_macros::*;
\nuse std::collections::HashMap;
\nuse std::sync::Arc;
\nuse tokio::sync::RwLock;<\/p>\n
\/\/ \u5168\u5c40\u8fde\u63a5\u7ba1\u7406\u5668
\nstruct ConnectionManager {
\n connections: Arc<RwLock<HashMap<String, Context>>>,
\n}<\/p>\n
impl ConnectionManager {
\n fn new() -> Self {
\n Self {
\n connections: Arc::new(RwLock::new(HashMap::new())),
\n }
\n }<\/p>\n
async fn add_connection(&self, id: String, ctx: Context) {
\n self.connections.write().await.insert(id, ctx);
\n }<\/p>\n
async fn remove_connection(&self, id: &str) {
\n self.connections.write().await.remove(id);
\n }<\/p>\n
async fn broadcast(&self, message: &str) {
\n let connections = self.connections.read().await;
\n for (id, ctx) in connections.iter() {
\n let _ = ctx.set_response_body(message).await.send_body().await;
\n }
\n }<\/p>\n
async fn send_to_user(&self, user_id: &str, message: &str) {
\n if let Some(ctx) = self.connections.read().await.get(user_id) {
\n let _ = ctx.set_response_body(message).await.send_body().await;
\n }
\n }
\n}<\/p>\n
\/\/ \u5168\u5c40\u8fde\u63a5\u7ba1\u7406\u5668\u5b9e\u4f8b
\nstatic CONNECTION_MANAGER: once_cell::sync::Lazy<ConnectionManager> =
\n once_cell::sync::Lazy::new(ConnectionManager::new);<\/p>\n
\/\/ \u7fa4\u804aWebSocket\u5904\u7406
\n#[ws]
\n#[get]
\nasync fn chat_handler(ctx: Context) {
\n let user_id = generate_user_id();<\/p>\n
\/\/ \u6dfb\u52a0\u5230\u8fde\u63a5\u7ba1\u7406\u5668
\n CONNECTION_MANAGER.add_connection(user_id.clone(), ctx.clone()).await;<\/p>\n
\/\/ \u53d1\u9001\u6b22\u8fce\u6d88\u606f
\n let welcome_msg = format!("User {} joined the chat", user_id);
\n CONNECTION_MANAGER.broadcast(&welcome_msg).await;<\/p>\n
\/\/ \u5904\u7406\u7528\u6237\u6d88\u606f
\n loop {
\n let message = ctx.get_request_body().await;
\n if message.is_empty() {
\n break;
\n }<\/p>\n
let chat_message = format!("User {}: {}", user_id, String::from_utf8_lossy(&message));
\n CONNECTION_MANAGER.broadcast(&chat_message).await;
\n }<\/p>\n
\/\/ \u7528\u6237\u65ad\u5f00\u8fde\u63a5
\n CONNECTION_MANAGER.remove_connection(&user_id).await;
\n let leave_msg = format!("User {} left the chat", user_id);
\n CONNECTION_MANAGER.broadcast(&leave_msg).await;
\n}<\/p>\n
fn generate_user_id() -> String {
\n use rand::Rng;
\n let mut rng = rand::thread_rng();
\n format!("user_{}", rng.gen_range(1000..9999))
\n}<\/p>\n
\u5728\u6211\u7684\u6821\u56ed\u4e8c\u624b\u4ea4\u6613\u5e73\u53f0\u9879\u76ee\u4e2d，\u6211\u5b9e\u73b0\u4e86\u4e00\u4e2a\u5b8c\u6574\u7684\u5b9e\u65f6\u804a\u5929\u7cfb\u7edf\u3002\u8fd9\u4e2a\u7cfb\u7edf\u9700\u8981\u652f\u6301\u7528\u6237\u4e4b\u95f4\u7684\u79c1\u804a\u3001\u7fa4\u804a\u3001\u6d88\u606f\u5386\u53f2\u8bb0\u5f55\u7b49\u529f\u80fd\u3002<\/p>\n
use hyperlane::*;
\nuse hyperlane_macros::*;
\nuse std::collections::HashMap;
\nuse std::sync::Arc;
\nuse tokio::sync::{broadcast, RwLock};
\nuse serde::{Deserialize, Serialize};<\/p>\n
#[derive(Clone, Serialize, Deserialize)]
\nstruct ChatMessage {
\n user_id: u32,
\n content: String,
\n timestamp: chrono::DateTime<chrono::Utc>,
\n message_type: MessageType,
\n}<\/p>\n
#[derive(Clone, Serialize, Deserialize)]
\nenum MessageType {
\n Text,
\n Image,
\n File,
\n System,
\n}<\/p>\n
#[derive(Clone)]
\nstruct ChatRoom {
\n id: u32,
\n name: String,
\n users: Arc<RwLock<HashMap<u32, String>>>,
\n tx: broadcast::Sender<ChatMessage>,
\n}<\/p>\n
impl ChatRoom {
\n fn new(id: u32, name: String) -> Self {
\n let (tx, _) = broadcast::channel(1000);
\n Self {
\n id,
\n name,
\n users: Arc::new(RwLock::new(HashMap::new())),
\n tx,
\n }
\n }<\/p>\n
async fn add_user(&self, user_id: u32, username: String) {
\n let mut users = self.users.write().await;
\n users.insert(user_id, username);<\/p>\n
\/\/ \u53d1\u9001\u7cfb\u7edf\u6d88\u606f
\n let system_msg = ChatMessage {
\n user_id: 0,
\n content: format!("{} joined the chat", username),
\n timestamp: chrono::Utc::now(),
\n message_type: MessageType::System,
\n };
\n let _ = self.tx.send(system_msg);
\n }<\/p>\n
async fn remove_user(&self, user_id: u32) {
\n let mut users = self.users.write().await;
\n if let Some(username) = users.remove(&user_id) {
\n \/\/ \u53d1\u9001\u7cfb\u7edf\u6d88\u606f
\n let system_msg = ChatMessage {
\n user_id: 0,
\n content: format!("{} left the chat", username),
\n timestamp: chrono::Utc::now(),
\n message_type: MessageType::System,
\n };
\n let _ = self.tx.send(system_msg);
\n }
\n }<\/p>\n
async fn broadcast_message(&self, message: ChatMessage) {
\n let _ = self.tx.send(message);
\n }
\n}<\/p>\n
\/\/ \u5168\u5c40\u804a\u5929\u5ba4\u7ba1\u7406\u5668
\nstruct ChatManager {
\n rooms: Arc<RwLock<HashMap<u32, ChatRoom>>>,
\n}<\/p>\n
impl ChatManager {
\n fn new() -> Self {
\n Self {
\n rooms: Arc::new(RwLock::new(HashMap::new())),
\n }
\n }<\/p>\n
async fn get_or_create_room(&self, room_id: u32, room_name: String) -> ChatRoom {
\n let mut rooms = self.rooms.write().await;
\n if let Some(room) = rooms.get(&room_id) {
\n room.clone()
\n } else {
\n let room = ChatRoom::new(room_id, room_name);
\n rooms.insert(room_id, room.clone());
\n room
\n }
\n }
\n}<\/p>\n
\/\/ WebSocket\u804a\u5929\u5904\u7406\u5668
\n#[ws]
\n#[get]
\nasync fn chat_handler(ctx: Context) {
\n let user_id = get_user_from_context(&ctx).await;
\n let room_id = ctx.get_route_param("room_id").await.parse::<u32>().unwrap_or(1);<\/p>\n
let chat_manager = ctx.get_data::<ChatManager>().await;
\n let room = chat_manager.get_or_create_room(room_id, format!("Room {}", room_id)).await;<\/p>\n
\/\/ \u6dfb\u52a0\u7528\u6237\u5230\u804a\u5929\u5ba4
\n room.add_user(user_id, format!("User {}", user_id)).await;<\/p>\n
\/\/ \u521b\u5efa\u6d88\u606f\u63a5\u6536\u5668
\n let mut rx = room.tx.subscribe();<\/p>\n
loop {
\n tokio::select! {
\n \/\/ \u63a5\u6536\u5ba2\u6237\u7aef\u6d88\u606f
\n message_result = ctx.get_request_body() => {
\n match message_result {
\n Ok(message_bytes) => {
\n if let Ok(message_str) = String::from_utf8(message_bytes) {
\n if let Ok(chat_message) = serde_json::from_str::<ChatMessage>(&message_str) {
\n \/\/ \u5e7f\u64ad\u6d88\u606f\u5230\u804a\u5929\u5ba4
\n room.broadcast_message(chat_message).await;
\n }
\n }
\n }
\n Err(_) => break, \/\/ \u8fde\u63a5\u65ad\u5f00
\n }
\n }<\/p>\n
\/\/ \u63a5\u6536\u5e7f\u64ad\u6d88\u606f
\n broadcast_result = rx.recv() => {
\n match broadcast_result {
\n Ok(message) => {
\n let message_json = serde_json::to_string(&message).unwrap();
\n let _ = ctx.set_response_body(message_json).await.send_body().await;
\n }
\n Err(_) => break, \/\/ \u5e7f\u64ad\u901a\u9053\u5173\u95ed
\n }
\n }
\n }
\n }<\/p>\n
\/\/ \u7528\u6237\u79bb\u5f00\u804a\u5929\u5ba4
\n room.remove_user(user_id).await;
\n}<\/p>\n
\/\/ \u83b7\u53d6\u804a\u5929\u5386\u53f2\u8bb0\u5f55
\n#[get]
\nasync fn get_chat_history(ctx: Context) {
\n let room_id = ctx.get_route_param("room_id").await;
\n let page = ctx.get_request_querys().await.get("page").unwrap_or("1").parse::<u32>().unwrap_or(1);
\n let limit = ctx.get_request_querys().await.get("limit").unwrap_or("50").parse::<u32>().unwrap_or(50);<\/p>\n
\/\/ \u4ece\u6570\u636e\u5e93\u83b7\u53d6\u804a\u5929\u5386\u53f2
\n let history = get_chat_history_from_db(room_id, page, limit).await;<\/p>\n
ctx.set_response_body_json(&history).await;
\n}<\/p>\n
\/\/ \u79c1\u804a\u529f\u80fd
\n#[ws]
\n#[get]
\nasync fn private_chat_handler(ctx: Context) {
\n let user_id = get_user_from_context(&ctx).await;
\n let target_user_id = ctx.get_route_param("target_id").await.parse::<u32>().unwrap_or(0);<\/p>\n
if target_user_id == 0 {
\n ctx.set_response_status_code(400).await;
\n return;
\n }<\/p>\n
\/\/ \u521b\u5efa\u79c1\u804a\u4f1a\u8bdd
\n let private_session = get_or_create_private_session(user_id, target_user_id).await;
\n let mut rx = private_session.tx.subscribe();<\/p>\n
loop {
\n tokio::select! {
\n \/\/ \u63a5\u6536\u5ba2\u6237\u7aef\u6d88\u606f
\n message_result = ctx.get_request_body() => {
\n match message_result {
\n Ok(message_bytes) => {
\n if let Ok(message_str) = String::from_utf8(message_bytes) {
\n if let Ok(chat_message) = serde_json::from_str::<ChatMessage>(&message_str) {
\n \/\/ \u53d1\u9001\u79c1\u804a\u6d88\u606f
\n private_session.send_message(chat_message).await;
\n }
\n }
\n }
\n Err(_) => break,
\n }
\n }<\/p>\n
\/\/ \u63a5\u6536\u79c1\u804a\u6d88\u606f
\n broadcast_result = rx.recv() => {
\n match broadcast_result {
\n Ok(message) => {
\n let message_json = serde_json::to_string(&message).unwrap();
\n let _ = ctx.set_response_body(message_json).await.send_body().await;
\n }
\n Err(_) => break,
\n }
\n }
\n }
\n }
\n}<\/p>\n
\/\/ \u5728\u7ebf\u7528\u6237\u5217\u8868
\n#[get]
\nasync fn get_online_users(ctx: Context) {
\n let room_id = ctx.get_route_param("room_id").await.parse::<u32>().unwrap_or(1);<\/p>\n
let chat_manager = ctx.get_data::<ChatManager>().await;
\n let room = chat_manager.get_or_create_room(room_id, format!("Room {}", room_id)).await;<\/p>\n
let users = room.users.read().await;
\n let user_list: Vec<String> = users.values().cloned().collect();<\/p>\n
ctx.set_response_body_json(&user_list).await;
\n}<\/p>\n
\/\/ \u6d88\u606f\u63a8\u9001\u670d\u52a1
\n#[post]
\nasync fn push_notification(ctx: Context) {
\n let notification: Notification = ctx.get_request_body_json().await;<\/p>\n
\/\/ \u53d1\u9001\u63a8\u9001\u901a\u77e5
\n send_push_notification(¬ification).await;<\/p>\n
ctx.set_response_status_code(200).await;
\n}<\/p>\n
#[derive(Deserialize)]
\nstruct Notification {
\n user_id: u32,
\n title: String,
\n content: String,
\n notification_type: String,
\n}<\/p>\n
\/\/ \u5b9e\u65f6\u6570\u636e\u540c\u6b65
\n#[ws]
\n#[get]
\nasync fn data_sync_handler(ctx: Context) {
\n let user_id = get_user_from_context(&ctx).await;
\n let sync_type = ctx.get_route_param("type").await;<\/p>\n
match sync_type.as_str() {
\n "orders" => {
\n \/\/ \u8ba2\u5355\u6570\u636e\u540c\u6b65
\n let mut order_rx = get_order_broadcast_channel().subscribe();
\n loop {
\n if let Ok(order_update) = order_rx.recv().await {
\n let order_json = serde_json::to_string(&order_update).unwrap();
\n let _ = ctx.set_response_body(order_json).await.send_body().await;
\n }
\n }
\n }
\n "products" => {
\n \/\/ \u5546\u54c1\u6570\u636e\u540c\u6b65
\n let mut product_rx = get_product_broadcast_channel().subscribe();
\n loop {
\n if let Ok(product_update) = product_rx.recv().await {
\n let product_json = serde_json::to_string(&product_update).unwrap();
\n let _ = ctx.set_response_body(product_json).await.send_body().await;
\n }
\n }
\n }
\n _ => {
\n ctx.set_response_status_code(400).await;
\n }
\n }
\n}<\/p>\n
\/\/ \u5b9e\u65f6\u76d1\u63a7\u548c\u7edf\u8ba1
\n#[get]
\nasync fn realtime_stats(ctx: Context) {
\n let stats = RealtimeStats {
\n online_users: get_online_user_count().await,
\n active_rooms: get_active_room_count().await,
\n messages_per_second: get_message_rate().await,
\n system_load: get_system_load().await,
\n };<\/p>\n
ctx.set_response_body_json(&stats).await;
\n}<\/p>\n
#[derive(Serialize)]
\nstruct RealtimeStats {
\n online_users: u32,
\n active_rooms: u32,
\n messages_per_second: f64,
\n system_load: f64,
\n}<\/p>\n
\/\/ \u9519\u8bef\u5904\u7406\u548c\u91cd\u8fde\u673a\u5236
\nasync fn handle_websocket_error(ctx: Context, error: Box<dyn std::error::Error>) {
\n let error_response = ErrorResponse {
\n error: "WebSocket error".to_string(),
\n message: error.to_string(),
\n timestamp: chrono::Utc::now(),
\n };<\/p>\n
let error_json = serde_json::to_string(&error_response).unwrap();
\n let _ = ctx.set_response_body(error_json).await.send_body().await;
\n}<\/p>\n
#[derive(Serialize)]
\nstruct ErrorResponse {
\n error: String,
\n message: String,
\n timestamp: chrono::DateTime<chrono::Utc>,
\n}<\/p>\n
\/\/ \u5ba2\u6237\u7aef\u91cd\u8fde\u903b\u8f91
\nconst ws = new WebSocket('ws:\/\/localhost:60000\/chat\/1');<\/p>\n
ws.onopen = () => {
\n console.log('Connected to chat room');
\n \/\/ \u53d1\u9001\u7528\u6237\u4fe1\u606f
\n ws.send(JSON.stringify({
\n user_id: 123,
\n content: "Hello everyone!",
\n timestamp: new Date().toISOString(),
\n message_type: "Text"
\n }));
\n};<\/p>\n
ws.onmessage = (event) => {
\n const message = JSON.parse(event.data);
\n console.log('Received:', message);<\/p>\n
\/\/ \u5904\u7406\u4e0d\u540c\u7c7b\u578b\u7684\u6d88\u606f
\n switch(message.message_type) {
\n case 'Text':
\n displayTextMessage(message);
\n break;
\n case 'System':
\n displaySystemMessage(message);
\n break;
\n case 'Image':
\n displayImageMessage(message);
\n break;
\n }
\n};<\/p>\n
ws.onclose = () => {
\n console.log('Connection closed, attempting to reconnect…');
\n setTimeout(() => {
\n \/\/ \u91cd\u8fde\u903b\u8f91
\n location.reload();
\n }, 3000);
\n};<\/p>\n
ws.onerror = (error) => {
\n console.error('WebSocket error:', error);
\n};<\/p>\n
\/\/ \u6d88\u606f\u663e\u793a\u51fd\u6570
\nfunction displayTextMessage(message) {
\n const chatContainer = document.getElementById('chat-container');
\n const messageElement = document.createElement('div');
\n messageElement.className = 'message text-message';
\n messageElement.innerHTML = `
\n <span class="username">User ${message.user_id}<\/span>
\n <span class="timestamp">${new Date(message.timestamp).toLocaleTimeString()}<\/span>
\n <div class="content">${message.content}<\/div>
\n `;
\n chatContainer.appendChild(messageElement);
\n chatContainer.scrollTop = chatContainer.scrollHeight;
\n}<\/p>\n
function displaySystemMessage(message) {
\n const chatContainer = document.getElementById('chat-container');
\n const messageElement = document.createElement('div');
\n messageElement.className = 'message system-message';
\n messageElement.innerHTML = `
\n <span class="system-text">${message.content}<\/span>
\n <span class="timestamp">${new Date(message.timestamp).toLocaleTimeString()}<\/span>
\n `;
\n chatContainer.appendChild(messageElement);
\n chatContainer.scrollTop = chatContainer.scrollHeight;
\n}<\/p>\n
function displayImageMessage(message) {
\n const chatContainer = document.getElementById('chat-container');
\n const messageElement = document.createElement('div');
\n messageElement.className = 'message image-message';
\n messageElement.innerHTML = `
\n <span class="username">User ${message.user_id}<\/span>
\n <span class="timestamp">${new Date(message.timestamp).toLocaleTimeString()}<\/span>
\n <img src="${message.content}" alt="Shared image" class="shared-image">
\n `;
\n chatContainer.appendChild(messageElement);
\n chatContainer.scrollTop = chatContainer.scrollHeight;
\n}<\/p>\n
\u6211\u66fe\u7ecf\u7528\u8fd9\u4e2a\u6846\u67b6\u5f00\u53d1\u8fc7\u4e00\u4e2a\u5728\u7ebf\u534f\u540c\u767d\u677f\u3002\u51e0\u5341\u4e2a\u7528\u6237\u53ef\u4ee5\u540c\u65f6\u7ed8\u5236，\u5ef6\u8fdf\u6781\u4f4e，\u8d44\u6e90\u5360\u7528\u7a33\u5b9a\u3002WebSocket \u548c SSE \u7684\u7ed3\u5408\u8ba9\u524d\u540e\u7aef\u5f00\u53d1\u90fd\u53d8\u5f97\u9ad8\u6548\u3002<\/p>\n
\/\/ \u534f\u540c\u767d\u677f\u5b9e\u73b0
\n#[ws]
\n#[get]
\nasync fn collaborative_whiteboard(ctx: Context) {
\n let user_id = get_user_from_context(&ctx).await;
\n let board_id = ctx.get_route_param("board_id").await;<\/p>\n
let board_manager = ctx.get_data::<WhiteboardManager>().await;
\n let board = board_manager.get_or_create_board(board_id).await;<\/p>\n
\/\/ \u6dfb\u52a0\u7528\u6237\u5230\u767d\u677f
\n board.add_user(user_id).await;<\/p>\n
let mut drawing_rx = board.get_drawing_channel().subscribe();<\/p>\n
loop {
\n tokio::select! {
\n \/\/ \u63a5\u6536\u7ed8\u5236\u6570\u636e
\n drawing_data = ctx.get_request_body() => {
\n if let Ok(data) = drawing_data {
\n if let Ok(drawing_event) = serde_json::from_slice::<DrawingEvent>(&data) {
\n \/\/ \u5e7f\u64ad\u7ed8\u5236\u4e8b\u4ef6
\n board.broadcast_drawing(drawing_event).await;
\n }
\n }
\n }<\/p>\n
\/\/ \u63a5\u6536\u5176\u4ed6\u7528\u6237\u7684\u7ed8\u5236
\n drawing_result = drawing_rx.recv() => {
\n if let Ok(drawing_event) = drawing_result {
\n let event_json = serde_json::to_string(&drawing_event).unwrap();
\n let _ = ctx.set_response_body(event_json).await.send_body().await;
\n }
\n }
\n }
\n }
\n}<\/p>\n
#[derive(Serialize, Deserialize)]
\nstruct DrawingEvent {
\n user_id: u32,
\n event_type: DrawingEventType,
\n x: f64,
\n y: f64,
\n color: String,
\n stroke_width: f32,
\n timestamp: chrono::DateTime<chrono::Utc>,
\n}<\/p>\n
#[derive(Serialize, Deserialize)]
\nenum DrawingEventType {
\n Start,
\n Move,
\n End,
\n Clear,
\n}<\/p>\n
\u5728\u6211\u7684\u534f\u540c\u767d\u677f\u9879\u76ee\u4e2d，\u6211\u8fdb\u884c\u4e86\u8be6\u7ec6\u7684\u6027\u80fd\u6d4b\u8bd5：<\/p>\n
\/\/ \u6027\u80fd\u6d4b\u8bd5\u4ee3\u7801
\nasync fn performance_test() {
\n let start_time = std::time::Instant::now();
\n let mut handles = vec![];<\/p>\n
\/\/ \u6a21\u62df100\u4e2a\u5e76\u53d1\u7528\u6237
\n for i in 0..100 {
\n let handle = tokio::spawn(async move {
\n let ws = create_websocket_connection().await;<\/p>\n
\/\/ \u53d1\u90011000\u6761\u6d88\u606f
\n for j in 0..1000 {
\n let message = format!("Message {} from user {}", j, i);
\n ws.send(message).await;<\/p>\n
\/\/ \u6a21\u62df\u7ed8\u5236\u64cd\u4f5c
\n let drawing_event = DrawingEvent {
\n user_id: i,
\n event_type: DrawingEventType::Move,
\n x: (j as f64) * 0.1,
\n y: (i as f64) * 0.1,
\n color: "#000000".to_string(),
\n stroke_width: 2.0,
\n timestamp: chrono::Utc::now(),
\n };<\/p>\n
let event_json = serde_json::to_string(&drawing_event).unwrap();
\n ws.send(event_json).await;
\n }
\n });
\n handles.push(handle);
\n }<\/p>\n
\/\/ \u7b49\u5f85\u6240\u6709\u4efb\u52a1\u5b8c\u6210
\n for handle in handles {
\n handle.await.unwrap();
\n }<\/p>\n
let duration = start_time.elapsed();
\n println!("Performance test completed in {:?}", duration);
\n println!("Average latency: {:?}", duration \/ 100000); \/\/ 1000 messages per user
\n}<\/p>\n
\u6d4b\u8bd5\u7ed3\u679c\u663e\u793a：<\/p>\n
\u901a\u8fc7\u8fd9\u4e2a\u9879\u76ee\u7684\u5b9e\u8df5，\u6211\u603b\u7ed3\u51fa\u4e86\u51e0\u4e2a\u91cd\u8981\u7684\u7ecf\u9a8c：<\/p>\n
\u5b9e\u65f6\u901a\u4fe1\u6280\u672f\u6b63\u5728\u5feb\u901f\u53d1\u5c55，\u4ece\u6700\u521d\u7684\u8f6e\u8be2\u5230 WebSocket，\u518d\u5230\u73b0\u5728\u7684 Server-Sent Events \u548c WebRTC\u3002\u8fd9\u4e2a Rust \u6846\u67b6\u8ba9\u6211\u770b\u5230\u4e86\u5b9e\u65f6\u901a\u4fe1\u7684\u672a\u6765\u65b9\u5411：<\/p>\n
\u4f5c\u4e3a\u4e00\u4e2a\u5373\u5c06\u6bd5\u4e1a\u7684\u8ba1\u7b97\u673a\u79d1\u5b66\u5b66\u751f，\u8fd9\u6b21\u5b9e\u65f6\u901a\u4fe1\u7684\u5f00\u53d1\u7ecf\u5386\u8ba9\u6211\u5bf9\u73b0\u4ee3 Web \u6280\u672f\u6709\u4e86\u66f4\u6df1\u7684\u8ba4\u8bc6\u3002\u5b9e\u65f6\u901a\u4fe1\u4e0d\u4ec5\u4ec5\u662f\u6280\u672f\u95ee\u9898，\u66f4\u662f\u7528\u6237\u4f53\u9a8c\u548c\u4ea7\u54c1\u7ade\u4e89\u529b\u7684\u5173\u952e\u56e0\u7d20\u3002<\/p>\n
\u8fd9\u4e2a Rust \u6846\u67b6\u8ba9\u6211\u770b\u5230\u4e86\u5b9e\u65f6 Web \u5e94\u7528\u7684\u672a\u6765：\u9ad8\u6027\u80fd\u3001\u4f4e\u5ef6\u8fdf\u3001\u9ad8\u5e76\u53d1\u3001\u6613\u6269\u5c55\u3002\u5b83\u4e0d\u4ec5\u4ec5\u662f\u4e00\u4e2a\u6846\u67b6，\u66f4\u662f\u5b9e\u65f6\u901a\u4fe1\u6280\u672f\u7684\u96c6\u5927\u6210\u8005\u3002<\/p>\n
\u6211\u76f8\u4fe1，\u968f\u7740 5G\u3001\u7269\u8054\u7f51\u7b49\u6280\u672f\u7684\u53d1\u5c55，\u5b9e\u65f6\u901a\u4fe1\u5c06\u4f1a\u5728\u66f4\u591a\u9886\u57df\u53d1\u6325\u91cd\u8981\u4f5c\u7528，\u800c\u8fd9\u4e2a\u6846\u67b6\u5c06\u4e3a\u5f00\u53d1\u8005\u63d0\u4f9b\u5f3a\u5927\u7684\u6280\u672f\u652f\u6491\u3002<\/p>\n
\u8fd9\u7bc7\u6587\u7ae0\u8bb0\u5f55\u4e86\u6211\u4f5c\u4e3a\u4e00\u4e2a\u5927\u4e09\u5b66\u751f\u5bf9\u5b9e\u65f6 Web \u901a\u4fe1\u6280\u672f\u7684\u63a2\u7d22\u5386\u7a0b\u3002\u901a\u8fc7\u5b9e\u9645\u7684\u9879\u76ee\u5f00\u53d1\u548c\u6027\u80fd\u6d4b\u8bd5，\u6211\u6df1\u523b\u4f53\u4f1a\u5230\u4e86\u5b9e\u65f6\u901a\u4fe1\u5728\u73b0\u4ee3 Web \u5e94\u7528\u4e2d\u7684\u91cd\u8981\u6027\u3002\u5e0c\u671b\u6211\u7684\u7ecf\u9a8c\u80fd\u591f\u4e3a\u5176\u4ed6\u540c\u5b66\u63d0\u4f9b\u4e00\u4e9b\u53c2\u8003\u3002<\/p>\n
\u66f4\u591a\u4fe1\u606f\u8bf7\u8bbf\u95ee Hyperlane GitHub \u9875\u9762 \u6216\u8054\u7cfb\u4f5c\u8005：root@ltpp.vip<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb903\u6b21\uff0c\u70b9\u8d5e17\u6b21\uff0c\u6536\u85cf26\u6b21\u3002Hyperlane is a lightweight and high-performance Rust HTTP server library designed to simplify network service development. It supports HTTP request parsing, response building, TCP communication, and redirection features, making it ideal for building modern<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[99,206,87,292,190,478,957],"topic":[],"class_list":["post-48776","post","type-post","status-publish","format-standard","hentry","category-server","tag-java","tag-rust","tag-87","tag-292","tag-190","tag-478","tag-957"],"yoast_head":"\n