news 2026/10/19 16:42:26

【消息队列项目】客户端搭建与测试

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
【消息队列项目】客户端搭建与测试

目录

一.广播交换模式下的测试

1.1.生产者消费者代码编写

1.2.测试

二.直接交换模式下的测试

2.1.生产者消费者代码编写

2.2.测试

三.主题交换模式下的测试

3.1.生产者消费者代码编写

3.2.测试

搭建客户端

  • 发布消息的生产者客户端
  • 订阅消息的消费者客户端

思想

  • 必须要有一个生产者客户端
  • 声明一个交换机
  • 声明一个队列1，binding_key=queue1
  • 声明一个队列2，binding_key=news.music.#
  • 将两个队列和交换机绑定起来
  • 搭建两个消费者客户端，分别订阅一个队列的消息

测试

  • 第一次，将交换机类型设置为广播模式，理论结果两个消费者客户端都能拿到消息
  • 第二次，将交换机类型设置为直接交换模式，routing_key=queue1 ,理论结果，只有订阅了队列1消息的客户端能拿到消息
  • 第三次，将交换机类型设置为主题交换，routing_key=news.music.pop，理论结果只有订阅了队列2消息的客户端能拿到消息

一.广播交换模式下的测试

1.1.生产者消费者代码编写

生产者客户端实现

#include "connection.hpp" int main() { // 1. 创建异步工作线程对象，用于处理网络IO mymq::AsyncWorker::ptr awp = std::make_shared<mymq::AsyncWorker>(); // 2. 建立与RabbitMQ服务器的连接 mymq::Connection::ptr conn = std::make_shared<mymq::Connection>("127.0.0.1", 8085, awp); // 3. 通过连接创建信道 mymq::Channel::ptr channel = conn->openChannel(); // 4. 声明交换机和队列，并建立绑定关系 // 使用空的属性映射（不设置额外参数） google::protobuf::Map<std::string, std::string> tmp_map; // 4.1 声明一个名为"exchange1"的广播交换机（ExchangeType::FANOUT） // 参数：交换机名称、类型、是否持久化、是否自动删除、额外属性 channel->declareExchange("exchange1", mymq::ExchangeType::FANOUT, true, false, tmp_map); // 4.2 声明一个持久化队列"queue1" // 参数：队列名称、是否持久化、是否排他、是否自动删除、额外属性 channel->declareQueue("queue1", true, false, false, tmp_map); // 4.3 声明一个持久化队列"queue2" channel->declareQueue("queue2", true, false, false, tmp_map); // 4.4 将队列"queue1"绑定到交换机"exchange1" channel->queueBind("exchange1", "queue1", "queue1"); // 4.5 将队列"queue2"绑定到交换机"exchange1" channel->queueBind("exchange1", "queue2", "news.music.#"); // 5. 发布消息到交换机 // 发送10条消息，所有绑定队列都会收到 for (int i = 0; i < 10; i++) { // 发布消息：交换机名称、消息属性、消息内容 channel->basicPublish("exchange1", nullptr, "Hello World-" + std::to_string(i)); } // 6. 关闭信道 conn->closeChannel(channel); return 0; }

消费者

#include "connection.hpp" #include <iostream> #include <thread> #include <chrono> #include <functional> // 消息消费回调函数 // 参数： // channel: 消息通道指针，用于发送确认消息等操作 // consumer_tag: 消费者标签，标识不同的消费者 // bp: 消息基本属性，包含消息ID、路由键等信息 // body: 消息体内容 void cb(mymq::Channel::ptr &channel, const std::string consumer_tag, const mymq::BasicProperties *bp, const std::string &body) { // 打印消费者信息和接收到的消息内容 std::cout << consumer_tag << "消费了消息：" << body << std::endl; // 发送消息确认，告诉RabbitMQ消息已被成功处理 // 参数：消息唯一ID channel->basicAck(bp->id()); } int main(int argc, char *argv[]) { // 检查命令行参数：需要指定要消费的队列名称 if (argc != 2) { std::cout << "使用方法: ./consume_client <队列名称>\n"; std::cout << "示例: ./consume_client queue1\n"; return -1; } // 1. 创建异步工作线程对象，用于处理网络IO和消息回调 mymq::AsyncWorker::ptr awp = std::make_shared<mymq::AsyncWorker>(); // 2. 建立与RabbitMQ服务器的连接 // 参数：服务器地址、端口号、异步工作线程 mymq::Connection::ptr conn = std::make_shared<mymq::Connection>("127.0.0.1", 8085, awp); // 3. 通过连接创建信道，信道是执行AMQP操作的通道 mymq::Channel::ptr channel = conn->openChannel(); // 4. 声明交换机和队列，并建立绑定关系 // 使用空的属性映射（不设置额外参数） google::protobuf::Map<std::string, std::string> tmp_map; // 4.1 声明一个名为"exchange1"的直接交换机（ExchangeType::FANOUT） // 参数：交换机名称、类型、是否持久化、是否自动删除、额外属性 channel->declareExchange("exchange1", mymq::ExchangeType::FANOUT, true, false, tmp_map); // 4.2 声明一个持久化队列"queue1" // 参数：队列名称、是否持久化、是否排他、是否自动删除、额外属性 channel->declareQueue("queue1", true, false, false, tmp_map); // 4.3 声明一个持久化队列"queue2" channel->declareQueue("queue2", true, false, false, tmp_map); // 4.4 将队列"queue1"绑定到交换机"exchange1"，绑定键为"queue1" // 参数：交换机名称、队列名称、绑定键 channel->queueBind("exchange1", "queue1", "queue1"); // 4.5 将队列"queue2"绑定到交换机"exchange1"，绑定键为"news.music.#" // "#"是通配符，表示匹配多个单词 channel->queueBind("exchange1", "queue2", "news.music.#"); // 5. 使用std::bind创建回调函数适配器 // std::bind将回调函数cb与参数绑定，其中channel作为第一个参数固定传入 // std::placeholders::_1、_2、_3代表回调函数cb的consumer_tag、bp、body参数 auto functor = std::bind(cb, channel, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3); // 6. 开始消费指定队列的消息 // 参数： // consumer1: 消费者标签，用于标识此消费者 // argv[1]: 队列名称，从命令行参数获取 // false: 是否自动确认消息，false表示需要手动确认（basicAck） // functor: 消息到达时的回调函数 channel->basicConsume("consumer1", argv[1], false, functor); // 7. 保持程序运行，等待消息 // 使用无限循环，每3秒休眠一次，避免CPU占用过高 while(1) { std::this_thread::sleep_for(std::chrono::seconds(3)); } // 8. 关闭信道（这里不会被执行，因为程序一直循环等待消息） conn->closeChannel(channel); return 0; }

makefile

all: publish_client consume_client publish_client: publish_client.cc ../third/include/muduo/protobuf/codec.cc ../mqcommon/msg.pb.cc ../mqcommon/proto.pb.cc g++ $^ -o $@ -I ../third/include -L ../third/lib -lmuduo_net -lmuduo_base -lpthread -lprotobuf -lz -lsqlite3 consume_client: consume_client.cc ../third/include/muduo/protobuf/codec.cc ../mqcommon/msg.pb.cc ../mqcommon/proto.pb.cc g++ $^ -o $@ -I ../third/include -L ../third/lib -lmuduo_net -lmuduo_base -lpthread -lprotobuf -lz -lsqlite3 .PHONY: clean clean: rm -rf publish_client consume_client

1.2.测试

没有问题，接下来我们就进入我们的测试环节

首先我们先启动服务器

服务器已经运行起来了

我们先运行消费者客户端

./consume_client queue1

换一个终端

./consume_client queue2

换一个终端

./publish_client

运行之后，我们发现绑定了queue1或者queue2的都收到了消息

二.直接交换模式下的测试

2.1.生产者消费者代码编写

生产者

#include "connection.hpp" int main() { // 1. 创建异步工作线程对象，用于处理网络IO mymq::AsyncWorker::ptr awp = std::make_shared<mymq::AsyncWorker>(); // 2. 建立与RabbitMQ服务器的连接 mymq::Connection::ptr conn = std::make_shared<mymq::Connection>("127.0.0.1", 8085, awp); // 3. 通过连接创建信道 mymq::Channel::ptr channel = conn->openChannel(); // 4. 声明交换机和队列，并建立绑定关系 // 使用空的属性映射（不设置额外参数） google::protobuf::Map<std::string, std::string> tmp_map; // 4.1 声明一个名为"exchange1"的直接交换机 // 参数：交换机名称、类型、是否持久化、是否自动删除、额外属性 channel->declareExchange("exchange1", mymq::ExchangeType::DIRECT, true, false, tmp_map); // 4.2 声明一个持久化队列"queue1" // 参数：队列名称、是否持久化、是否排他、是否自动删除、额外属性 channel->declareQueue("queue1", true, false, false, tmp_map); // 4.3 声明一个持久化队列"queue2" channel->declareQueue("queue2", true, false, false, tmp_map); // 4.4 将队列"queue1"绑定到交换机"exchange1" channel->queueBind("exchange1", "queue1", "queue1"); // 4.5 将队列"queue2"绑定到交换机"exchange1" channel->queueBind("exchange1", "queue2", "news.music.#"); // 5. 发布消息到交换机 // 发送4条消息，只有queue1能收到 for (int i = 0; i < 4; i++) { mymq::BasicProperties bp; bp.set_id(mymq::UUIDHelper::uuid()); // 设置消息唯一ID bp.set_delivery_mode(mymq::DeliveryMode::DURABLE); // 设置消息持久化 bp.set_routing_key("queue1"); // 设置路由键 // 发布消息：交换机名称、消息属性、消息内容 channel->basicPublish("exchange1", &bp, "Hello World-" + std::to_string(i)); } // 6. 关闭信道 conn->closeChannel(channel); return 0; }

消费者

#include "connection.hpp" #include <iostream> #include <thread> #include <chrono> #include <functional> // 消息消费回调函数 // 参数： // channel: 消息通道指针，用于发送确认消息等操作 // consumer_tag: 消费者标签，标识不同的消费者 // bp: 消息基本属性，包含消息ID、路由键等信息 // body: 消息体内容 void cb(mymq::Channel::ptr &channel, const std::string consumer_tag, const mymq::BasicProperties *bp, const std::string &body) { // 打印消费者信息和接收到的消息内容 std::cout << consumer_tag << "消费了消息：" << body << std::endl; // 发送消息确认，告诉RabbitMQ消息已被成功处理 // 参数：消息唯一ID channel->basicAck(bp->id()); } int main(int argc, char *argv[]) { // 检查命令行参数：需要指定要消费的队列名称 if (argc != 2) { std::cout << "使用方法: ./consume_client <队列名称>\n"; std::cout << "示例: ./consume_client queue1\n"; return -1; } // 1. 创建异步工作线程对象，用于处理网络IO和消息回调 mymq::AsyncWorker::ptr awp = std::make_shared<mymq::AsyncWorker>(); // 2. 建立与RabbitMQ服务器的连接 // 参数：服务器地址、端口号、异步工作线程 mymq::Connection::ptr conn = std::make_shared<mymq::Connection>("127.0.0.1", 8085, awp); // 3. 通过连接创建信道，信道是执行AMQP操作的通道 mymq::Channel::ptr channel = conn->openChannel(); // 4. 声明交换机和队列，并建立绑定关系 // 使用空的属性映射（不设置额外参数） google::protobuf::Map<std::string, std::string> tmp_map; // 4.1 声明一个名为"exchange1"的直接交换机 // 参数：交换机名称、类型、是否持久化、是否自动删除、额外属性 channel->declareExchange("exchange1", mymq::ExchangeType::DIRECT, true, false, tmp_map); // 4.2 声明一个持久化队列"queue1" // 参数：队列名称、是否持久化、是否排他、是否自动删除、额外属性 channel->declareQueue("queue1", true, false, false, tmp_map); // 4.3 声明一个持久化队列"queue2" channel->declareQueue("queue2", true, false, false, tmp_map); // 4.4 将队列"queue1"绑定到交换机"exchange1"，绑定键为"queue1" // 参数：交换机名称、队列名称、绑定键 channel->queueBind("exchange1", "queue1", "queue1"); // 4.5 将队列"queue2"绑定到交换机"exchange1"，绑定键为"news.music.#" // "#"是通配符，表示匹配多个单词 channel->queueBind("exchange1", "queue2", "news.music.#"); // 5. 使用std::bind创建回调函数适配器 // std::bind将回调函数cb与参数绑定，其中channel作为第一个参数固定传入 // std::placeholders::_1、_2、_3代表回调函数cb的consumer_tag、bp、body参数 auto functor = std::bind(cb, channel, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3); // 6. 开始消费指定队列的消息 // 参数： // consumer1: 消费者标签，用于标识此消费者 // argv[1]: 队列名称，从命令行参数获取 // false: 是否自动确认消息，false表示需要手动确认（basicAck） // functor: 消息到达时的回调函数 channel->basicConsume("consumer1", argv[1], false, functor); // 7. 保持程序运行，等待消息 // 使用无限循环，每3秒休眠一次，避免CPU占用过高 while(1) { std::this_thread::sleep_for(std::chrono::seconds(3)); } // 8. 关闭信道（这里不会被执行，因为程序一直循环等待消息） conn->closeChannel(channel); return 0; }

编译还是和上面一样

2.2.测试

注意：每次测试之前都需要删除/data目录，这里面存储的是持久化的绑定信息，我们需要将它们删除

没有问题，接下来我们就进入我们的测试环节

首先我们先启动服务器

服务器已经运行起来了

我们先运行消费者客户端

./consume_client queue1

换一个终端

./consume_client queue2

换一个终端

./publish_client

运行之后，我们发现绑定了queue1的消费者收到了消息

但是绑定queue2的消费者没有收到消息

三.主题交换模式下的测试

3.1.生产者消费者代码编写

生产者客户端实现

#include "connection.hpp" int main() { // 1. 创建异步工作线程对象，用于处理网络IO mymq::AsyncWorker::ptr awp = std::make_shared<mymq::AsyncWorker>(); // 2. 建立与RabbitMQ服务器的连接 // 参数：服务器地址、端口号、异步工作线程 mymq::Connection::ptr conn = std::make_shared<mymq::Connection>("127.0.0.1", 8085, awp); // 3. 通过连接创建信道 mymq::Channel::ptr channel = conn->openChannel(); // 4. 声明交换机和队列，并建立绑定关系 // 使用空的属性映射（不设置额外参数） google::protobuf::Map<std::string, std::string> tmp_map; // 4.1 声明一个名为"exchange1"的主题交换机（ExchangeType::TOPIC） // 参数：交换机名称、类型、是否持久化、是否自动删除、额外属性 channel->declareExchange("exchange1", mymq::ExchangeType::TOPIC, true, false, tmp_map); // 4.2 声明一个持久化队列"queue1" // 参数：队列名称、是否持久化、是否排他、是否自动删除、额外属性 channel->declareQueue("queue1", true, false, false, tmp_map); // 4.3 声明一个持久化队列"queue2" channel->declareQueue("queue2", true, false, false, tmp_map); // 4.4 将队列"queue1"绑定到交换机"exchange1"，绑定键为"queue1" // 参数：交换机名称、队列名称、绑定键 channel->queueBind("exchange1", "queue1", "queue1"); // 4.5 将队列"queue2"绑定到交换机"exchange1"，绑定键为"news.music.#" // "#"是通配符，表示匹配多个单词 channel->queueBind("exchange1", "queue2", "news.music.#"); // 5. 发布消息到交换机 // 5.1 发送10条路由键为"news.music.pop"的消息 for (int i = 0; i < 10; i++) { mymq::BasicProperties bp; bp.set_id(mymq::UUIDHelper::uuid()); // 设置消息唯一ID bp.set_delivery_mode(mymq::DeliveryMode::DURABLE); // 设置消息持久化 bp.set_routing_key("news.music.pop"); // 设置路由键 // 发布消息：交换机名称、消息属性、消息内容 channel->basicPublish("exchange1", &bp, "Hello World-" + std::to_string(i)); } // 5.2 发送一条路由键为"news.music.sport"的消息 mymq::BasicProperties bp; bp.set_id(mymq::UUIDHelper::uuid()); bp.set_delivery_mode(mymq::DeliveryMode::DURABLE); bp.set_routing_key("news.music.sport"); channel->basicPublish("exchange1", &bp, "Hello Bite"); // 5.3 发送一条路由键为"news.sport"的消息 // 注意：修改了同一个bp对象的路由键，会覆盖之前的设置 bp.set_routing_key("news.sport"); channel->basicPublish("exchange1", &bp, "Hello chileme?"); // 6. 关闭信道 conn->closeChannel(channel); return 0; }

消费者客户端实现

我们创建一个consume_client.cc，然后把下面这些内容填写进去即可

#include "connection.hpp" #include <iostream> #include <thread> #include <chrono> #include <functional> // 消息消费回调函数 // 参数： // channel: 消息通道指针，用于发送确认消息等操作 // consumer_tag: 消费者标签，标识不同的消费者 // bp: 消息基本属性，包含消息ID、路由键等信息 // body: 消息体内容 void cb(mymq::Channel::ptr &channel, const std::string consumer_tag, const mymq::BasicProperties *bp, const std::string &body) { // 打印消费者信息和接收到的消息内容 std::cout << consumer_tag << "消费了消息：" << body << std::endl; // 发送消息确认，告诉RabbitMQ消息已被成功处理 // 参数：消息唯一ID channel->basicAck(bp->id()); } int main(int argc, char *argv[]) { // 检查命令行参数：需要指定要消费的队列名称 if (argc != 2) { std::cout << "使用方法: ./consume_client <队列名称>\n"; std::cout << "示例: ./consume_client queue1\n"; return -1; } // 1. 创建异步工作线程对象，用于处理网络IO和消息回调 mymq::AsyncWorker::ptr awp = std::make_shared<mymq::AsyncWorker>(); // 2. 建立与RabbitMQ服务器的连接 // 参数：服务器地址、端口号、异步工作线程 mymq::Connection::ptr conn = std::make_shared<mymq::Connection>("127.0.0.1", 8085, awp); // 3. 通过连接创建信道，信道是执行AMQP操作的通道 mymq::Channel::ptr channel = conn->openChannel(); // 4. 声明交换机和队列，并建立绑定关系 // 使用空的属性映射（不设置额外参数） google::protobuf::Map<std::string, std::string> tmp_map; // 4.1 声明一个名为"exchange1"的主题交换机（ExchangeType::TOPIC） // 参数：交换机名称、类型、是否持久化、是否自动删除、额外属性 channel->declareExchange("exchange1", mymq::ExchangeType::TOPIC, true, false, tmp_map); // 4.2 声明一个持久化队列"queue1" // 参数：队列名称、是否持久化、是否排他、是否自动删除、额外属性 channel->declareQueue("queue1", true, false, false, tmp_map); // 4.3 声明一个持久化队列"queue2" channel->declareQueue("queue2", true, false, false, tmp_map); // 4.4 将队列"queue1"绑定到交换机"exchange1"，绑定键为"queue1" // 参数：交换机名称、队列名称、绑定键 channel->queueBind("exchange1", "queue1", "queue1"); // 4.5 将队列"queue2"绑定到交换机"exchange1"，绑定键为"news.music.#" // "#"是通配符，表示匹配多个单词 channel->queueBind("exchange1", "queue2", "news.music.#"); // 5. 使用std::bind创建回调函数适配器 // std::bind将回调函数cb与参数绑定，其中channel作为第一个参数固定传入 // std::placeholders::_1、_2、_3代表回调函数cb的consumer_tag、bp、body参数 auto functor = std::bind(cb, channel, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3); // 6. 开始消费指定队列的消息 // 参数： // consumer1: 消费者标签，用于标识此消费者 // argv[1]: 队列名称，从命令行参数获取 // false: 是否自动确认消息，false表示需要手动确认（basicAck） // functor: 消息到达时的回调函数 channel->basicConsume("consumer1", argv[1], false, functor); // 7. 保持程序运行，等待消息 // 使用无限循环，每3秒休眠一次，避免CPU占用过高 while(1) { std::this_thread::sleep_for(std::chrono::seconds(3)); } // 8. 关闭信道（这里不会被执行，因为程序一直循环等待消息） conn->closeChannel(channel); return 0; }

编译测试

我们可以先进行编译一下，

all: publish_client consume_client publish_client: publish_client.cc ../third/include/muduo/protobuf/codec.cc ../mqcommon/msg.pb.cc ../mqcommon/proto.pb.cc g++ $^ -o $@ -g -I ../third/include -L ../third/lib -lmuduo_net -lmuduo_base -lpthread -lprotobuf -lz -lsqlite3 consume_client: consume_client.cc ../third/include/muduo/protobuf/codec.cc ../mqcommon/msg.pb.cc ../mqcommon/proto.pb.cc g++ $^ -o $@ -g -I ../third/include -L ../third/lib -lmuduo_net -lmuduo_base -lpthread -lprotobuf -lz -lsqlite3 .PHONY: clean clean: rm -rf publish_client consume_client

3.2.测试

注意：每次测试之前都需要删除/data目录，这里面存储的是持久化的绑定信息，我们需要将它们删除

没有问题，接下来我们就进入我们的测试环节

首先我们先启动服务器

服务器已经运行起来了

我们先运行消费者客户端

./consume_client queue1

换一个终端

./consume_client queue2

换一个终端

./publish_client

运行之后，我们发现这个queue2的收到了消息

而绑定了queue1的客户端则没有任何反应

版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
网站建设 2026/10/17 21:55:54

PyTorch DataLoader多线程加载数据：提升GPU利用率

PyTorch DataLoader多线程加载数据&#xff1a;提升GPU利用率 在现代深度学习训练中&#xff0c;一个常见的怪象是&#xff1a;明明配备了A100这样的顶级GPU&#xff0c;监控工具却显示利用率长期徘徊在30%以下。计算资源闲置的同时&#xff0c;实验进度被严重拖慢——这背后往…

作者头像 李华
网站建设 2026/10/18 1:54:26

Docker Compose编排多个PyTorch服务：实现多任务并行处理

Docker Compose编排多个PyTorch服务&#xff1a;实现多任务并行处理 在现代AI系统开发中&#xff0c;一个常见的挑战是&#xff1a;如何在一个有限的硬件资源上&#xff0c;同时运行图像分类、目标检测、语义分割等多个深度学习模型&#xff1f;手动切换环境、反复安装依赖、GP…

作者头像 李华
网站建设 2026/10/16 21:17:30

使用PbootCMS制作网站如何免费做好防护

一、前期准备&#xff1a;备份与版本升级&#xff08;关键第一步&#xff09; 1. 全量备份&#xff08;避免操作失误&#xff09; 登录宝塔面板→【网站】 →【备份】→【立即备份】&#xff08;备份网站文件数据库&#xff09;。额外备份&#xff1a;通过阿里云控制台→【OS…

作者头像 李华
网站建设 2026/10/14 8:36:52

Markdown制作幻灯片：用于PyTorch项目汇报展示

Markdown制作幻灯片&#xff1a;用于PyTorch项目汇报展示 在深度学习项目的日常推进中&#xff0c;一个常被忽视却极为耗时的环节&#xff0c;是将实验结果整理成一份清晰、专业且可复现的汇报材料。许多团队仍依赖 PowerPoint 手动拼接截图、复制指标、调整排版——这一过程不…

作者头像 李华
网站建设 2026/10/17 7:38:09

GitHub Actions持续集成PyTorch模型测试用例

GitHub Actions 持续集成 PyTorch 模型测试用例 在现代深度学习项目中&#xff0c;代码提交后“本地能跑但上线报错”的尴尬场景屡见不鲜。尤其当模型涉及 GPU 加速、分布式训练或混合精度推理时&#xff0c;仅靠 CPU 环境的 CI 测试已远远不够。如何确保每一次 git push 都不会…

作者头像 李华
网站建设 2026/10/18 7:08:47

Java毕设选题推荐：基于SpringBoot+Vue的高尔夫球场服务系统设计与实现基于SpringBoot的高尔夫球场管理系统的设计与实现【附源码、mysql、文档、调试+代码讲解+全bao等】

博主介绍&#xff1a;✌️码农一枚 &#xff0c;专注于大学生项目实战开发、讲解和毕业&#x1f6a2;文撰写修改等。全栈领域优质创作者&#xff0c;博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java、小程序技术领域和毕业项目实战 ✌️技术范围&#xff1a;&am…

作者头像 李华