Rust学习笔记 - mpsc与消息通信

2026-08-30

全文 ≈ 1.2k字 | 预计阅读时长 5分钟

mpsc 是 multiple producer, single consumer 的缩写，表示多个发送端、一个接收端。它是一种常见的消息通信模型：多个地方可以把消息发送到同一个 channel 中，再由一个接收方按顺序取出并处理。

前言

写服务端时，很多模块都可能需要给同一个客户端发消息。比如登录回包、消息广播、系统通知，甚至定时任务产生的推送。如果这些模块都直接操作连接对象，代码很容易碰到借用和并发访问的问题，连接本身也会变得难以维护。

一种更自然的做法是，让连接只由一个地方持有，其他模块只负责投递消息，再由持有连接的任务统一写出。mpsc 适合解决的，正是这类“多处发送、单点处理”的通信问题。

标准库的 mpsc

先看一个简单的例子：

use std::sync::mpsc;

fn main() {
    let (tx, rx) = mpsc::channel();

    tx.send(String::from("hallo")).unwrap();

    let message = rx.recv().unwrap();
    println!("received: {}", message);
    // received: hallo
}

More >>

Rust学习笔记 - Arc、RwLock、Mutex及RefCell区别

2026-08-23

全文 ≈ 1.9k字 | 预计阅读时长 8分钟

最近在使用 Rust 重写一些老项目时，经常会碰到 Arc、RwLock、Mutex 以及 RefCell 这些类型。它们都和“共享”或“可变”有关，这里简单整理一下它们的区别和常见使用场景。

前言

假设现在设计一个在线用户管理模块，并且需要支持通过编号获取对应的用户实例，看起来这个需求不复杂，但如果再往前走一步，就会发现后面很快会碰到共享所有权和内部状态修改的问题。

先看一个最简单的版本：

pub struct User {
    pub id: u64,
    pub email: String,
}

pub struct UserMgr {
    users: HashMap<u64, User>,
}

impl UserMgr {
    pub fn new() -> Self {
        Self {
            users: HashMap::new(),
        }
    }

    pub fn get(&self, id: u64) -> Option<&User> {
        self.users.get(&id)
    }

    pub fn add(&mut self, user: User) {
        self.users.insert(user.id, user);
    }

    pub fn remove(&mut self, id: u64) {
        self.users.remove(&id);
    }
}

一开始这样写没什么问题，UserMgr 负责保存用户，通过 id 取出来就行了。

More >>

数据结构与算法 - Deque

2026-06-07

全文 ≈ 1.9k字 | 预计阅读时长 8分钟

Deque（Double-Ended Queue，双端队列）是一种允许在头尾两端进行插入和删除的线性数据结构。

前言

从定义上来看，Deque 只是比 Queue 多了一端的操作能力。但与 Queue 不同的是，Deque 同时具备 Stack 和 Queue 的访问模式，因此在需要灵活处理头尾两端元素的场景中广泛应用。

它们之间的区别很直观：

Queue: FIFO（First In, First Out，先进先出）

Deque: FIFO / LIFO（先进先出 / 后进先出）

More >>

数据结构与算法 - RVO

2026-05-21

全文 ≈ 1.7k字 | 预计阅读时长 6分钟

RVO（Reciprocal Velocity Obstacles，互惠速度障碍）是一种多人动态避障算法。

「数据结构与算法 - JPS 」兄弟篇

前言

如果 A*、JPS 等寻路算法解决的是“如何到达目的地”，那么 RVO 解决的就是“在移动过程中，如何避免与动态目标发生碰撞”。常用于游戏中多单位在移动过程中实现自动避让，比如：红警、星际争霸等RTS游戏。

可以通俗的理解为：每个移动的单位都会主动互相让一点，避免路径撞车。

这类动态避障算法的核心思想是：“按照当前速度继续移动，未来会不会发生碰撞？”，也就是 Velocity Obstacle（速度障碍）。

More >>

Rust学习笔记 - Axum

2026-05-10

全文 ≈ 1.4k字 | 预计阅读时长 7分钟

Axum 是由 Tokio 官方团队开发的一个高性能、设计优雅的现代化 Web 框架。

为什么选择Axum？

Tokio 是 Rust 社区中最流行的异步编程框架之一（在区块链和智能合约圈子比较受欢迎），而Axum是由Tokio官方开发、且深度集成的Web框架。

快速使用

假设已经安装了Rust开发环境

// main.rs
use axum::{Router, routing};
use tokio::net::TcpListener;

#[tokio::main]
async fn main() {
    let router = Router::new().route("/", routing::get(async || "Hi, Rust!"));
    let addr = "0.0.0.0:8000";
    let listener = TcpListener::bind(&addr).await.unwrap();
    println!("listening on {}", addr);
    axum::serve(listener, router).await.unwrap();
}

1 2	$ curl -X GET 'http://127.0.0.1:8000' Hi, Rust!

More >>

逆向学习笔记 - Cocos2d JS逆向提取资源

2026-01-14

全文 ≈ 563字 | 预计阅读时长 2分钟

记一次半吊子逆向工程的…不那么艰难的过程。

「逆向学习笔记 - Cocos2d Lua逆向提取资源」难弟篇

前言

最近刷到一款某道换皮手游，玩法和美术风格都是我喜欢的类型。于是想着做点逆向学习，顺便捞一手美术资源。

动手

一个某道换皮手游，解压安装包：

├── AndroidManifest.xml
├── assets
│   ├── assets
│   ├── jsb-adapter
│   ├── main.js
│   ├── project.json
│   └── src
├── classes.dex
├── kotlin
│   └── ...
├── lib
│   ├── arm64-v8a
│   ├── armeabi-v7a
│   ├── x86
│   └── x86_64
├── META-INF
│   ├── CERT.RSA
│   ├── CERT.SF
│   ├── com
│   └── MANIFEST.MF
├── org
│   └── cocos2dx
├── res
│   └── ...
└── resources.arsc

More >>

数据结构与算法 - DAG

2025-12-30

全文 ≈ 670字 | 预计阅读时长 2分钟

有向无环图（Directed Acyclic Graph，简称 DAG）是一种图结构，由若干顶点和带方向的边组成。与普通有向图不同的是，DAG 中不存在环路——也就是说，不可能从某个顶点出发，沿着边的方向走一圈，最终又回到原点。

背景

项目QueryBuilder模块初始指标依赖层级相对固定，但版本多次迭代后，指标之间逐渐形成了复杂的依赖路径。原有的逻辑已无法支持，所以引入有向无环图（DAG），用于对指标依赖关系进行建模和解析。

定义

DAG 中的每个节点只关心两类关系：我依赖的和依赖我的。

type Node struct {
    dependencies []*Node // 当前节点依赖的前置节点
    dependents   []*Node // 依赖当前节点的后置节点
}

More >>

数据结构与算法 - Power of Two Choices

2025-05-22

全文 ≈ 389字 | 预计阅读时长 1分钟

两次随机选择法（Power of Two Choices，简称 P2C）是一种高效的负载均衡算法。

背景

实现连接池负载均衡

实现思路

连接池

type ConnPool struct {
    conns []*conn
    i     uint32
}

type conn struct {
    clientConn *grpc.ClientConn
    streams    int32
}

More >>