升压消息队列 两个进程间没有接收消息

Question

我写了一个小的测试应用程序，使用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();
};

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

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

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

在你的例子中，系统进程应该启动队列，测试应用程序连接，然后他们可以通信。这也是为什么重启测试应用时能正常工作的原因。

这样设计是为了防止低权限用户未经许可访问高权限用户内存。