c++ - Boost消息队列未跨两个进程接收

Question

我编写了一个小型测试应用程序，以使用Boos Message_Queue在两个进程之间发送数据。一切正常，我能够打印发送的数据。

我将测试代码移到了主项目中，现在主项目没有从接收器中醒来。主项目作为系统运行，因此我找到了一个错误，并发现由于某种原因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();
};

测试应用程序的运行代码:(我一直在使用断点)

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);
    }
}

似乎不是代码问题，因为它可以在测试应用程序中运行，但在主项目中却不能共享代码。

我很茫然。

Answer 1

对于进程间通信，必须首先启动更高特权的进程。只有这样，低特权进程才能连接。

在您的示例系统进程中，应该启动队列，测试应用程序连接，然后它们才能进行通信。这就是为什么在重新启动测试应用程序时它可以工作的原因。

通过这种方式可以防止低权限用户未经许可访问高权限用户内存。