当前位置： 首页 > wzjs >正文

襄阳市建设厅官方网站手机端网站开发语言

wzjs 2025/9/14 9:52:01
襄阳市建设厅官方网站,手机端网站开发语言,哪有备案好的网站,网站建设的发展趋势前言 开发设计时，通常会对业务流程进行模块化，有些流程之间，不要求同步，但又需要传递信息时，如果存储到数据库，效率降低很多，如果是存放在内存是最好的。此时可以选择系统的IPC（进程…

前言

        开发设计时，通常会对业务流程进行模块化，有些流程之间，不要求同步，但又需要传递信息时，如果存储到数据库，效率降低很多，如果是存放在内存是最好的。此时可以选择系统的IPC（进程间通信，如共享内存等），本文讲解的是适合轻量级的队列缓存场景的mqueue。

功能讲解

mqueue特性

        Linux的mqueue（消息队列）是POSIX标准中定义的进程间通信（IPC）机制，允许不同进程通过内核维护的队列传递结构化消息。其具备以下几个特性：

  • 存储在指定文件：mqueue消息队列文件默认挂载在/dev/mqueue目录下。通过mq_open创建的消息队列会在此目录生成对应文件节点，内核使用红黑树管理消息的存储与优先级
  • 持久性：POSIX消息队列随系统重启消失
  • 可在命令行查看队列信息：cat /dev/mqueue/[队列名]  # 查看队列属性（如最大消息数、消息大小）

功能介绍

需求场景：某些功能需要在root用户下作为服务执行，组装的生产数据需要推送给登录系统桌面的普通用户权限的应用。

下面以在root权限下运行的读取usb信息的服务，监测USB的插拔事件并把信息推送到mqueue，而普通用户的应用通过读取mqueue获取USB插拔信息为例。

获取事件信息写入mqueue

#ifndef USBACTION_H_
#define USBACTION_H_
#include <unistd.h>
#include <cstring>
#include <iostream>
#include <sstream>
#include <string>
#include <algorithm>
#include <vector>#include <cstdio>
#include <stdio.h>
#include <dlfcn.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <libudev.h>
#include <mqueue.h>
using namespace std;
#define MAX_NUM 100struct Message {long mtype; // 消息类型char mtext[256]; // 消息内容
};const int MSG_TYPE = 1;
const char* QUEUE_NAME = "/usb_msg";//在/dev/mqueue目录下class Usbaction: public TUtilBase {
public:Usbaction();~Usbaction();int Run();private://int Init();//初始化void monitorDevices();int sendtomqueue(const char* mqstr);unsigned int uSleepTime;                //刷新间隔};#endif /* USBACTION_H_ */

#include "usbaction.h"std::vector<std::string> split(const std::string& str, char delimiter) {std::vector<std::string> tokens;std::istringstream tokenStream(str);std::string token;while (std::getline(tokenStream, token, delimiter)) {tokens.push_back(token);}return tokens;
}Usbaction::Usbaction() {uSleepTime = 5;
}Usbaction::~Usbaction() {
}int Usbaction::sendtomqueue(const char* mqstr){mqd_t mq;struct mq_attr attr;attr.mq_flags = O_NONBLOCK;  // 设置为非阻塞模式attr.mq_maxmsg = MAX_NUM;	 // 队列中最大消息数attr.mq_msgsize = sizeof(Message);// 消息的最大大小（字节）attr.mq_curmsgs = 0;         // 队列中当前消息数mq = mq_open(QUEUE_NAME, O_CREAT | O_WRONLY, 0644, &attr);if (mq == (mqd_t)-1) {WRITELOG(LOG_ERROR,"mq_open Error");return 0;}Message msg;msg.mtype = MSG_TYPE;strcpy(msg.mtext,mqstr);//attr.mq_flags |= O_NONBLOCK;if (mq_setattr(mq, &attr, NULL) == -1) {return 0;}if (mq_send(mq, reinterpret_cast<char*>(&msg), sizeof(msg), 0) == -1) {if (errno == EAGAIN) {} else {perror("mq_send");}}else {std::cout << "Message sent: " << msg.mtext << std::endl;}// 关闭消息队列mq_close(mq);return 1;
}void Usbaction::monitorDevices() {// 创建 udev 对象struct udev *udev = udev_new();if (!udev) {return;}// 创建 udev 监视器struct udev_monitor *mon = udev_monitor_new_from_netlink(udev, "udev");if (!mon) {udev_unref(udev);return;}// 添加过滤器以匹配usb 子系统udev_monitor_filter_add_match_subsystem_devtype(mon, "usb", nullptr);udev_monitor_enable_receiving(mon);std::cout << "Monitoring block and USB events. Press Ctrl+C to exit." << std::endl;while (true) {struct udev_device *dev = udev_monitor_receive_device(mon);if (dev) {bool bfind=false;std::string level="";const char* subsystem = udev_device_get_subsystem(dev);const char* action = udev_device_get_action(dev);const char* devnode = udev_device_get_devnode(dev);const char *pro = udev_device_get_property_value(dev, "ID_USB_INTERFACES");if (subsystem && action && devnode) {if (strcmp(action,"add")==0||strcmp(action,"remove")==0){bfind=true;std::vector<std::string> tokens = split(devnode, '/');// 确保有至少两个分割结果if (tokens.size() >= 2) {string device = tokens[tokens.size() - 1];string bus = tokens[tokens.size() - 2];level = bus + ":" + device;}}}if (bfind) {const char* idVendor = udev_device_get_sysattr_value(dev,"idVendor");const char* idProduct = udev_device_get_sysattr_value(dev, "idProduct");if (idVendor && idProduct) {//strcmp(action,"add")==0char sendbuf[256]={0};if(pro){sprintf(sendbuf,"%s,%s,%s:%s,%s",action,level.c_str(),idVendor,idProduct,pro);}elsesprintf(sendbuf,"%s,%s,%s:%s",action,level.c_str(),idVendor,idProduct);sendtomqueue(sendbuf);
%s",action,level.c_str(),idVendor,idProduct);}else{char sendbuf[256]={0};sprintf(sendbuf,"%s,%s",action,level.c_str());sendtomqueue(sendbuf);}}udev_device_unref(dev);}usleep(500000); // Sleep for 0.5 seconds}udev_monitor_unref(mon);udev_unref(udev);
}int Usbaction::Init() {//logif (0== BInit(APP_TYPE_LOG, ACTIVITYCENSUS_LOG, 0)) {return 0;}return 1;
}int Usbaction::Run() {//初始化if (NS_FAILED == Init()) {return 0;}monitorDevices();return 1;
}int main(int argc, char **argv) {Usbaction action;action.Run();return 0;}

makefile

CC        = g++
CFLAGS    =
DEBUGFLAG = -g -Wall
MACRO     =
#MACRO     = -D_DEBUG 
LIBDIRS   = 
LIBS      = -ldl -ludev -lrt
INCLUDE   = 
MAKE_SO   = 
OPTIONS   = 
OBJDIR    =
SRCDIR    =
RUNOUTPUT = usbaction
LIBOUTPUT =
OBJS      = usbaction.odefault:$(RUNOUTPUT)clean:rm -f $(OBJS) $(RUNOUTPUT)install:cp -f $(RUNOUTPUT) ../../bin$(RUNOUTPUT):$(OBJS)$(CC)   -o $(RUNOUTPUT) $^ $(OPTIONS)  $(LIBDIRS) $(LIBS).cpp.o:$(CC) $(DEBUGFLAG) $(MACRO) -fPIC -c $< -o $@ $(CFLAGS) $(INCLUDE)

读取mqueue

普通应用权限的应用可以读取root用户权限的mqueue文件，下面是非阻塞式读取队列数据。

#include <iostream>
#include <mqueue.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <cstring>
#include <unistd.h>struct Message {long mtype;        // 消息类型char mtext[256];   // 消息内容
};const char* QUEUE_NAME = "/ymore_msg"; // 消息队列的名称int main() {// 打开消息队列以读取模式mqd_t mq = mq_open(QUEUE_NAME, O_RDONLY | O_NONBLOCK);if (mq == (mqd_t)-1) {std::cerr << "Error opening message queue: " << strerror(errno) << std::endl;return 1;}Message msg;ssize_t bytes_read;// 循环接收消息while (true) {bytes_read = mq_receive(mq, reinterpret_cast<char*>(&msg), sizeof(msg), NULL);if (bytes_read == -1) {std::cerr << "Error receiving message: " << strerror(errno) << std::endl;break;}std::cout << "Received message: " << msg.mtext << std::endl;// 如果读取到队列为空，可以根据条件退出// 例如，使用 `mq_getattr()` 获取队列的当前状态struct mq_attr attr;if (mq_getattr(mq, &attr) == -1) {std::cerr << "Error getting queue attributes: " << strerror(errno) << std::endl;break;}// 如果队列中没有消息，退出循环if (attr.mq_curmsgs == 0) {std::cout << "No more messages in the queue." << std::endl;break;}}// 关闭消息队列mq_close(mq);return 0;
}

结尾

        Linux后台C/C++项目，一般在架构设计时，可以设计共享内容来内部处理缓存数据，但也有考虑到第三方应用或者扩展型应用的场景，此时mqueue是比较合适了，如果是高并发的队列缓存，还是得找成熟的队列缓存中间件，比如kafka。


文章转载自：

http://iYT9uAgt.djmdk.cn
http://uiYMsyS9.djmdk.cn
http://91jkrsNE.djmdk.cn
http://0qcQhT9u.djmdk.cn
http://cah43LHC.djmdk.cn
http://ciWaLIPq.djmdk.cn
http://60leD6Ip.djmdk.cn
http://Qr727KcU.djmdk.cn
http://pkNcliRg.djmdk.cn
http://YmG8yvLw.djmdk.cn
http://CXh8l8Pr.djmdk.cn
http://s8qDnZt4.djmdk.cn
http://rBsydJbZ.djmdk.cn
http://IKe5X5Mn.djmdk.cn
http://yGjR9Upj.djmdk.cn
http://8ZMFjr8w.djmdk.cn
http://6MiMULqx.djmdk.cn
http://CCMesXwH.djmdk.cn
http://uORpxZLw.djmdk.cn
http://T2xiFBuj.djmdk.cn
http://5JWAqHen.djmdk.cn
http://OllRCbJs.djmdk.cn
http://v6tJdhKM.djmdk.cn
http://nwSIKWme.djmdk.cn
http://XyhzZoxq.djmdk.cn
http://58sjU4vZ.djmdk.cn
http://1dSb3718.djmdk.cn
http://LcC2Zt3c.djmdk.cn
http://EnARLAJ8.djmdk.cn
http://eonjJc0I.djmdk.cn
http://www.dtcms.com/wzjs/728429.html

相关文章：

  • 杭州 电商设计网站建设政务网站模版
  • asp网站开发的实训大学html网站建设作业
  • 国产做的视频网站如何开发游戏软件
  • 搭建什么网站最赚钱忘记了wordpress登录密码
  • 恭城网站建设医疗网站建设案例
  • 手机和pc网站网络服务公司经营范围
  • 大网站开发万网 网站建设
  • 重庆做网站多少钱网站建设销售是什么
  • 北京网站设计技术wordpress透明主题下载
  • 望城警务督察网站建设传奇游戏开发
  • 手机网站建设注册塔山双喜用html5做的网站的原代码
  • 郑州中心站铜川公司做网站
  • 小说网站静态页面模板制作图片教程
  • 网站策划与网页设计长沙招聘网官网
  • 云南云桥建设股份有限公司官方网站重庆 网站 建设
  • asp.net mvc5网站开发之美摄影网站的设计
  • 织梦 导航网站 模板在线美图
  • 东营网站建设app开发怎样用dede搭建网站
  • 博达软件网站建设做网站如何选主机
  • 网站开发项目报价建设一个网站app全过程
  • 广州个人网站制作公司网站域名如何备案信息
  • 网站建设规划面试技巧青岛网站建设套餐报价
  • 网站文章收录苏州绿叶网站建设
  • 成都网站只网页设计与制作教程第三版答案
  • 重庆建工信息网官网长春seo排名公司
  • 对于做网站有什么要求科技成果鉴定机构
  • 创建一个网站要多少钱视频转文字网页
  • 菜鸟如何做网站深圳十大网络推广公司排名
  • 外贸最大电子元器件交易网站外贸网站仿牌主机
  • 计算机应用技术移动互联网开发五合一网站做优化好用吗