可以使用serde_json库来解析和序列化JSON消息。以下是一个示例代码，演示了如何在Actix WebSocket处理程序中使用serde_json库来处理JSON消息：

use actix::prelude::*;
use actix_web_actors::ws;
use serde::{Deserialize, Serialize};
use serde_json::{json, Value};

#[derive(Debug, Serialize, Deserialize)]
struct Message {
    action: String,
    payload: Value,
}

struct MyWebSocket;

impl Actor for MyWebSocket {
    type Context = ws::WebsocketContext;

    fn started(&mut self, ctx: &mut Self::Context) {
        // 在这里可以进行一些初始化操作
    }
}

impl StreamHandler> for MyWebSocket {
    fn handle(&mut self, msg: Result, ctx: &mut Self::Context) {
        match msg {
            Ok(ws::Message::Text(text)) => {
                let message: Message = match serde_json::from_str(&text) {
                    Ok(r) => r,
                    Err(e) => {
                        println!("JSON解析失败: {:?}", e);
                        return;
                    }
                };
                println!("收到的消息：{:?}", message);
            }
            Ok(ws::Message::Close(reason)) => {
                println!("WebSocket已关闭: {:?}", reason);
                ctx.stop();
            }
            _ => (),
        }
    }
}

impl Handler for MyWebSocket {
    type Result = ();

    fn handle(&mut self, msg: ws::Message, ctx: &mut Self::Context) -> Self::Result {
        match msg {
            ws::Message::Text(text) => {
                let message: Message = match serde_json::from_str(&text) {
                    Ok(r) => r,
                    Err(e) => {
                        println!("JSON解析失败: {:?}", e);
                        return;
                    }
                };
                println!("收到的消息：{:?}", message);

                // 这里可以根据消息内容执行逻辑操作

                // 发送响应消息
                let response = json!({
                    "status": "ok",
                    "message": "收到了你的消息",
                });
                ctx.text(response.to_string());
            }
            _ => (),
        }
    }
}

fn websocket_route(r: &mut web::ServiceConfig) {
    r.route("/ws/", web::get().to(|| {
        ws::start(MyWebSocket, &HttpRequest::default(), None)
    }));
}

fn main() {
    HttpServer::new(|| {
        App::new()
            .service(websocket_route)
    })
    .bind("127.0