1

这是一个使用套接字在应用程序之间创建一些临时进程间通信的测试。这些应用程序稍后将在不同的系统上运行，使用定制的嵌入式通信系统，但目前后者不可用。因此，我正在寻找一种快速（甚至可能有点脏）的 c++ 方法来实现这些应用程序之间的进程间通信。应用程序将发送一些字符串（所以没什么太花哨的）。

我偶然发现了oscpack，它udp用于实现开放式声音控制的消息传递。我已经在 linux 中将它编译为 gcc4.7.1 作为共享对象，使用make lib. 请注意，我必须-fPIC在.COPTSMakefile

有了共享库，我编写了一个小的概念验证应用程序，它使用一个单独的线程来监听消息，并在主线程中等待某个字符串stdin将其转发到另一个应用程序。我执行此应用程序的 2 个非常相似的实例。只是在第二种情况下，我交换了PORT_RCV和PORT_SND数字。

实际问题从这里开始：

我面临的问题是，在接收端，当对osc::UdpSocket::ReceiveFrom()（最终运行 recvfrom()）的调用解除阻塞时，我得到的读取字节的返回值等于零 (0)。此外，char * data指针仍指向零。所以本质上我没有收到来自发送者应用程序的字符串，即使 recvfrom() 在正确的时间解除阻塞。

从手册页中我读到，当发送方关闭连接时，recv 和 recvfrom 可以返回值 0。但在这种情况下，发件人使用的是 udp，即无连接...连接:)，所以我不确定它是否适用于此。

我尝试使用netcat在相应端口中侦听 udp 消息并验证至少发送方部分是否有效。事实上netcat -u -l -p <sender port of the running instance>，我确实收到了我输入的消息。所以问题可能与接收端有关。

问题是：我是否正确使用了 recvfrom ？

请找到附加到进程间通信测试应用程序的代码（实际上是一个全双工信使）。要执行其中的两个，首先下载并编译为库oscpack库。然后将下面的源代码复制到两个文件中，并交换第二个源文件中的PORT_RCV和PORT_SND数字。

然后编译每个：

#compile
g++ -g -Wall -Wextra -pedantic -std=c++11  -I../oscpack -c -o "obj_dbg/messenger.opp" "src/messenger.cpp"

#link
g++ -g -Wall -Wextra -pedantic -std=c++11  -I../oscpack  obj_dbg/messenger.opp -o "messenger_dbg" -L../oscpack -pthread -loscpack

然后执行它们并输入一个单词，按 Enter 并期望（不）看到它出现在其他应用程序中。

#include <iostream>
#include <string>
#include <string.h>

#include <thread>

#include <unistd.h>

#include "osc/OscReceivedElements.h"
#include "osc/OscPacketListener.h"
#include "ip/UdpSocket.h"

#include "osc/OscOutboundPacketStream.h"
#include "ip/UdpSocket.h"

using namespace std;
using namespace osc;

#define ADDRESS "127.0.0.1"
#define PORT_RCV 34343U
#define PORT_SND 34344U

#define IP_MTU_SIZE 1536

class EnaluPacketListener : public OscPacketListener
{
    protected:
        void ProcessMessage( const ReceivedMessage& m, const IpEndpointName& /*remoteEndpoint*/ )
        {
            //ReceivedMessageArgumentStream args = m.ArgumentStream();
            ReceivedMessage::const_iterator arg = m.ArgumentsBegin();
            try{
                if( strcmp( m.AddressPattern(), "/info" ) == 0 )
                {
                    msg.clear();
                    msg = (arg++)->AsString();
                    //args >> msg >> EndMessage;
                    if( arg != m.ArgumentsEnd() )
                        std::cout << "more args exist\n";
                }
            }
            catch( Exception& e )
            {
                // any parsing errors such as unexpected argument types, or
                // missing arguments get thrown as exceptions.
                std::cout << "error while parsing message: "
                << m.AddressPattern() << ": " << e.what() << "\n";
            }
        }
    public:
        std::string msg;
};



void sendMsg(UdpTransmitSocket & transmitSocket , std::string const & msgTitle , std::string const & msg)
{
    char buffer[IP_MTU_SIZE];
    osc::OutboundPacketStream p( buffer, IP_MTU_SIZE );

    p.Clear();
    //p << osc::BeginBundleImmediate;
    p << osc::BeginMessage( msgTitle.c_str() );
    p << msg.c_str();
    p << osc::EndMessage;
    //p << osc::EndBundle;

    transmitSocket.Send( p.Data(), p.Size() );
}


void rcvThread(bool bExit)
{
    IpEndpointName ipen(ADDRESS,PORT_RCV);
    UdpReceiveSocket s(ipen);
    EnaluPacketListener pckParser;
    IpEndpointName ipenRcv;
    char * buffer = nullptr;
    int bufferSize = 0U;
    while (!bExit)
    {
        std::cout << "hello1\n";
        int i = s.ReceiveFrom(ipenRcv,buffer,bufferSize);
        if (i > 0)
        {
            std::cout << "bufferSize=" << bufferSize << " , buffer: " << buffer << std::endl;
            //we have data
            pckParser.ProcessPacket(buffer,bufferSize,ipenRcv);
            std::cout << "rcved: "  << pckParser.msg << "\n";
        }
        sleep(1);
    }
}

//int main(int argc, char* argv[])
int main(int , char**)
{
    bool bExit = false;
    UdpTransmitSocket transmitSocket( IpEndpointName( ADDRESS, PORT_SND ) );

    std::thread thr(rcvThread, std::ref(bExit));

    std::string str;
    while (!bExit)
    {
        std::cin >> str;
        if ((!str.empty()) && (str.compare("q") != 0))
            sendMsg(transmitSocket,"info",str);
        else
            bExit = true;
    }

    thr.join();

    return 0;
}
4

1 回答 1

1 
char * buffer = nullptr;
int bufferSize = 0U;

问题就在这里。

    int i = s.ReceiveFrom(ipenRcv,buffer,bufferSize);

您告诉ReceiveFrom()接收到一个由空指针指向的零长度缓冲区，它确实如此，并返回零。它还能做什么？改成：

char buffer[4096]; // or whatever you need
// ...
int i = s.ReceiveFrom(ipenRcv,buffer,sizeof buffer);
于 2016-11-17T00:01:31.473 回答