从0到1搭建外卖跑腿配送系统全流程解析

2026-07-02 75

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 这是一套“多角色+实时调度+地理位置驱动”的同城即时履约系统，涵盖用户、商家、骑手、管理后台四端。详解了分层微服务架构、核心派单算法（Redis GEO+距离匹配）、WebSocket实时推送、高并发处理及进阶AI调度方案，助你落地可商用的外卖跑腿系统。（239字）

外卖跑腿配送系统本质上是一个“多角色 + 实时调度 + 地理位置驱动”的同城即时履约系统，核心围绕四个端：用户端、商家端、骑手端、管理后台。

下面从业务流程到技术架构，再到核心代码实现，带你完整拆解一套可落地的系统设计。
外卖跑腿配送系统.png

一、系统整体架构设计

一个标准外卖跑腿系统通常采用分层+微服务/模块化架构：

1. 业务端结构

用户端：下单、支付、追踪订单
商家端：接单、出餐、订单管理
骑手端：抢单/派单、配送、签收
管理后台：订单调度、风控、数据分析

2. 技术架构

前端：Vue / React / 小程序 / App
后端：Java Spring Boot / Node.js / Go
数据库：MySQL + Redis
地图服务：高德 / Google Maps
消息系统：WebSocket / MQTT
定位系统：GPS + LBS

二、核心业务流程

外卖跑腿系统的主链路：

用户下单
商家接单
系统派单（或抢单）
骑手接单
骑手取餐
骑手配送
完成订单
结算与评价

关键点在第3步：派单逻辑

三、核心模块拆解

1. 订单模块

订单是整个系统的核心数据结构。

示例：订单表设计（简化）

CREATE TABLE orders (
    id BIGINT PRIMARY KEY AUTO_INCREMENT,
    user_id BIGINT,
    merchant_id BIGINT,
    rider_id BIGINT,
    status VARCHAR(20),
    total_amount DECIMAL(10,2),
    create_time DATETIME,
    update_time DATETIME
);

2. 下单接口（后端示例）

Node.js 示例

app.post("/order/create", async (req, res) => {
   
    const {
    userId, merchantId, items } = req.body;

    // 1. 计算金额
    const total = items.reduce((sum, item) => {
   
        return sum + item.price * item.count;
    }, 0);

    // 2. 创建订单
    const order = await db.orders.create({
   
        user_id: userId,
        merchant_id: merchantId,
        total_amount: total,
        status: "PENDING"
    });

    // 3. 写入Redis用于派单
    await redis.lpush("order_queue", order.id);

    res.json({
   
        success: true,
        orderId: order.id
    });
});

3. 派单核心逻辑（重点）

外卖系统“智能化”的核心就在这里：如何匹配最近骑手

思路：

获取订单位置
查找附近骑手（LBS）
计算距离
分配最近骑手

Redis GEO实现骑手定位

// 骑手上线（存位置）
await redis.geoadd(
    "riders_location",
    longitude,
    latitude,
    riderId
);

查询附近骑手

const riders = await redis.georadius(
    "riders_location",
    orderLng,
    orderLat,
    3,          // 3公里范围
    "km",
    "WITHDIST",
    "COUNT",
    5
);

派单逻辑（核心代码）

async function dispatchOrder(orderId, orderLng, orderLat) {
   
    const riders = await redis.georadius(
        "riders_location",
        orderLng,
        orderLat,
        5,
        "km",
        "WITHDIST"
    );

    if (!riders.length) {
   
        throw new Error("暂无可用骑手");
    }

    // 按距离排序
    riders.sort((a, b) => a[1] - b[1]);

    const selectedRider = riders[0][0];

    // 更新订单
    await db.orders.update({
   
        where: {
    id: orderId },
        data: {
   
            rider_id: selectedRider,
            status: "DISPATCHED"
        }
    });

    // 通知骑手（WebSocket/MQTT）
    notifyRider(selectedRider, orderId);

    return selectedRider;
}

4. 实时订单推送（WebSocket）

骑手必须“秒级收到订单”

const WebSocket = require("ws");

const wss = new WebSocket.Server({
    port: 8080 });

wss.on("connection", (ws) => {
   
    ws.on("message", (msg) => {
   
        const data = JSON.parse(msg);

        if (data.type === "rider_login") {
   
            ws.riderId = data.riderId;
        }
    });
});

// 推送订单
function notifyRider(riderId, orderId) {
   
    wss.clients.forEach(client => {
   
        if (client.riderId === riderId) {
   
            client.send(JSON.stringify({
   
                type: "NEW_ORDER",
                orderId
            }));
        }
    });
}

5. 骑手接单逻辑

app.post("/rider/accept", async (req, res) => {
   
    const {
    riderId, orderId } = req.body;

    const order = await db.orders.findById(orderId);

    if (order.status !== "DISPATCHED") {
   
        return res.json({
    success: false, msg: "订单已被接单" });
    }

    await db.orders.update({
   
        where: {
    id: orderId },
        data: {
   
            status: "ACCEPTED",
            rider_id: riderId
        }
    });

    res.json({
    success: true });
});

6. 定位更新（骑手端）

骑手位置需要持续上报：

setInterval(() => {
   
    navigator.geolocation.getCurrentPosition(async (pos) => {
   
        await fetch("/rider/location/update", {
   
            method: "POST",
            body: JSON.stringify({
   
                riderId,
                lng: pos.coords.longitude,
                lat: pos.coords.latitude
            })
        });
    });
}, 5000);

后端存储更新：

app.post("/rider/location/update", async (req, res) => {
   
    const {
    riderId, lng, lat } = req.body;

    await redis.geoadd("riders_location", lng, lat, riderId);

    res.json({
    success: true });
});

四、关键技术难点

1. 高并发订单处理

Redis队列削峰
MQ异步派单
分库分表

2. 实时性

WebSocket替代HTTP轮询
MQTT优化移动端连接

3. 距离计算

Redis GEO（推荐）
Haversine公式（备用）

4. 防止抢单冲突

分布式锁（Redis SETNX）

const lock = await redis.set("order_lock_" + orderId, riderId, "NX", "EX", 10);
if (!lock) {
   
    return "订单已被抢";
}

五、系统升级方向（进阶）

如果要做商业级系统，必须加：

智能派单（AI算法：距离+负载+评分）
动态调度（订单合并配送）
路径规划优化（A* / Dijkstra）
风控系统（异常骑手检测）
大数据分析（热区预测）

外卖跑腿配送系统.png

六、总结

外卖跑腿配送系统的核心不是“下单”，而是：

实时调度 + 地理位置 + 多角色协同

真正的技术难点集中在三点：

派单算法
实时通信
高并发处理

如果这三块做好，系统才算真正可商用。