以下是一个使用 C++ 的示例，展示如何从 MongoDB 查询经纬度数据，并通过 UDP 将其发送给客户端。我们将使用 MongoDB C++ 驱动和 POSIX sockets 进行 UDP 通信。
前提条件
- 确保已安装 MongoDB C++ 驱动（可以参考 MongoDB 官方文档）。
- 使用标准的
<sys/socket.h>和<netinet/in.h>库进行 UDP 通信。
示例代码
#include <iostream>#include <mongocxx/client.hpp>#include <mongocxx/instance.hpp>#include <mongocxx/uri.hpp>#include <bsoncxx/json.hpp>#include <cstring>#include <sys/socket.h>#include <netinet/in.h>#include <unistd.h>struct Location {std::string name;double latitude;double longitude;};int main() {// 初始化 MongoDB 驱动mongocxx::instance instance{};mongocxx::client client{mongocxx::uri{}};auto collection = client["your_database_name"]["your_collection_name"];std::vector<Location> locations;// 查询数据auto cursor = collection.find({});for (auto&& doc : cursor) {Location loc;loc.name = bsoncxx::string::to_string(doc["name"].get_utf8().value);loc.latitude = doc["latitude"].get_double();loc.longitude = doc["longitude"].get_double();locations.push_back(loc);}// 创建 UDP socketint sockfd = socket(AF_INET, SOCK_DGRAM, 0);if (sockfd < 0) {perror("socket creation failed");exit(EXIT_FAILURE);}struct sockaddr_in servaddr;memset(&servaddr, 0, sizeof(servaddr));servaddr.sin_family = AF_INET; // IPv4servaddr.sin_port = htons(8080); // 客户端端口servaddr.sin_addr.s_addr = inet_addr("127.0.0.1"); // 客户端 IP// 打包数据为 JSON 格式字符串std::string jsonData = "[";for (size_t i = 0; i < locations.size(); ++i) {jsonData += "{\"name\":\"" + locations[i].name + "\",\"latitude\":" +std::to_string(locations[i].latitude) + ",\"longitude\":" +std::to_string(locations[i].longitude) + "}";if (i != locations.size() - 1) jsonData += ",";}jsonData += "]";// 发送数据到客户端ssize_t sentBytes = sendto(sockfd, jsonData.c_str(), jsonData.length(), MSG_CONFIRM,(const struct sockaddr *) &servaddr,sizeof(servaddr));if (sentBytes == -1) {perror("sendto failed");} else {std::cout << "Data sent: " << jsonData << std::endl;}close(sockfd);return 0;}
编译与运行
确保链接了必要的库。在 Ubuntu 上，可以使用以下命令：
g++ -o udp_mongodb_sender udp_mongodb_sender.cpp `pkg-config --cflags --libs libmongocxx` -lstdc++
然后运行程序：
./udp_mongodb_sender
注意事项：
- 请确保 MongoDB 服务正在运行，并且数据库和集合名称正确。
- 根据需要修改 IP 地址和端口号，以便将数据发送到适当的客户端地址。
- 如果没有安装相关的库，请按照官方文档进行安装配置。
内容由零声教学AI助手提供，问题来源于学员提问
