c++ - 提升消息队列未跨两个进程接收
问题描述
我编写了一个小型测试应用程序来使用 Boos Message_Queue 在两个进程之间发送数据。一切正常,我能够打印我发送的数据。
我将我的测试代码移到了我的主项目中,现在主项目没有从 Receives 中唤醒。主项目作为系统运行,所以我追踪了一个错误,发现 message_queue 出于某种原因没有检查相同的内存位置。我定义了 BOOST_INTERPROCESS_SHARED_DIR_PATH,然后主项目能够打开测试应用程序创建的队列。但是当测试应用程序发送时,主项目从未从它的接收中醒来。主项目应该作为系统运行,测试应用程序作为用户运行。但我想既然它正在共享内存位置,它应该可以正常工作吗?
如果我再次在测试应用程序中打开队列,它会立即唤醒并接收所有消息。我是否遗漏了什么或者这是对 BOOST message_queue 的限制?
来自测试应用程序的代码:
MessageQueue::MessageQueue(int, boost::interprocess::permissions perm) :
mq(boost::interprocess::create_only, "TestChannel", 100, sizeof(QueueData), perm)
{
}
MessageQueue::MessageQueue(bool) :
mq(boost::interprocess::open_only, "TestChannel")
{
}
MessageQueue::~MessageQueue()
{
int num = mq.get_num_msg();
wprintf(_T("sent: %d\n"), num);
boost::interprocess::message_queue::remove("TestChannel");
}
void MessageQueue::SetCommand(int i)
{
QueueData qd;
qd.fakeInfo = i;
qd.exit = false;
CoCreateGuid(&qd.msgGuid);
mq.send(&qd, sizeof(qd), 0);
OLECHAR* uidOleStr;
if (StringFromCLSID(qd.msgGuid, &uidOleStr) != S_OK)
throw std::runtime_error("Unknown error occurred when trying to convert a GUID to string!");
// Copy the ole str into a CString and then free it immediately, so we don't have to worry about it.
CString guidString(uidOleStr);
CoTaskMemFree(uidOleStr);
wprintf(_T("sent: %d, %s\n"), qd.fakeInfo, guidString);
}
void MessageQueue::WaitForCommand()
{
while(true)
{
QueueData qd;
size_t size, pri;
mq.receive(&qd, sizeof(qd), size, pri);
if (qd.fakeInfo == 2)
sendExit();
OLECHAR* uidOleStr;
if (StringFromCLSID(qd.msgGuid, &uidOleStr) != S_OK)
throw std::runtime_error("Unknown error occurred when trying to convert a GUID to string!");
// Copy the ole str into a CString and then free it immediately, so we don't have to worry about it.
CString guidString(uidOleStr);
CoTaskMemFree(uidOleStr);
wprintf(_T("Recieved: %d, %s\n"), qd.fakeInfo, guidString);
if (qd.exit)
break;
}
}
void MessageQueue::sendExit()
{
QueueData qd;
qd.exit = true;
mq.send(&qd, sizeof(qd), 0);
wprintf(_T("Sent Exit"));
}
.h 文件:
#pragma once
#define BOOST_INTERPROCESS_SHARED_DIR_PATH "C:\\Program Files (x86)\\Users"
#include <boost/interprocess/ipc/message_queue.hpp>
#include <boost/interprocess/permissions.hpp>
class QueueData
{
public:
int fakeInfo;
GUID msgGuid;
bool exit;
};
class MessageQueue
{
public:
MessageQueue(int, boost::interprocess::permissions perm);
MessageQueue(bool);
~MessageQueue();
boost::interprocess::message_queue mq;
void SetCommand(int);
void WaitForCommand();
void sendExit();
};
测试app运行代码:(我一直在使用断点)
void waiter()
{
MessageQueue mq(true);
mq.WaitForCommand();
}
void sender()
{
boost::interprocess::permissions perm;
perm.set_unrestricted();
try
{
boost::interprocess::message_queue::remove("TestChannel");
MessageQueue mq(2, perm);
mq.SetCommand(1);
mq.SetCommand(1);
mq.SetCommand(2);
}
catch (boost::interprocess::interprocess_exception e)
{
}
}
int main() {
waiter();
sender();
}
来自主项目的代码:(为了测试我确实使用了上面代码的等待,但仍然没有)
void MemoryChannel::WaitForCmd( const std::function< void ( MemoryChannelCmd cmd, const char *pData, TCHAR *tempPath, GUID msgGuid ) > func )
{
QueueData mcObject;
size_t size, pri;
while (true)
{
pMCD->dataQueue.timed_receive(&mcObject, sizeof(mcObject), size, pri, boost::posix_time::microsec_clock::universal_time() + boost::posix_time::milliseconds(30000));
size_t num = pMCD->dataQueue.get_num_msg();
//func(MemoryChannelCmd::MEMORY_CHANNEL_RUN_SQL_SELECT, "", _T(""), mcObject.msgGuid);
}
}
似乎不是代码问题,因为它适用于测试应用程序,但不适用于主项目,甚至共享代码。
我很茫然。
解决方案
对于进程间通信,必须首先启动更高权限的进程。只有这样,较低权限的进程才能连接。
在您的示例系统进程应该启动队列,测试应用程序连接,然后他们可以通信。这就是重新启动测试应用程序时它起作用的原因。
它的设计是为了防止低权限用户在未经许可的情况下访问高权限用户内存。
推荐阅读
- xcode - Xcode 性能
- neo4j - Neo4j:如何满足第一次看到的发件人+第一次看到多个收件人的附件
- java - 访问包含 postfix 的服务器并使用它从 Spring Boot 应用程序发送邮件
- python - 加速 Dijkstra 算法
- javascript - 如何从 dc.js selectMenu 中删除附加提示选项“全选”?
- python - 使用列表选择具有多个条件的数据框记录
- algorithm - RDD连续子集的Scala Spark执行
- android - DataBindingUtil 将布局膨胀为空
- mysql - 如何更改 mySQL 中的存储引擎?
- reactjs - .net core 3.1 with react - 根据身份角色渲染导航菜单项