spieleprogrammierer.de - Forum und Wiki zur Spieleprogrammierung und Spieleentwicklung

C-/C++-Quelltext

int main()
{
    // Prepare our context and socket
    zmq::context_t context(1);
    zmq::socket_t socket(context, ZMQ_REP);
    socket.bind("tcp://127.0.0.1:5555");



        zmq::message_t request;

        // Wait for next request from client
        socket.recv(&request,0);

        MainMessage message;

        message.ParseFromArray(request.data(),request.size());
        MessageLogin login = message.GetExtension(MessageLogin::Login);
        std::string user = login.username();
        std::string pw = login.password();
        std::cout << message.header().msgid() << std::endl;
        std::cout << user << std::endl;
        std::cout << pw << std::endl;
        
        message.ClearExtension(MessageLogin::Login);
        message.Clear();

        // Send reply back to client

        MainMessage proto_reply;
        MessageHeader header;
        header.set_msgid(1);
        header.set_sid(0);
        proto_reply.set_allocated_header(&header);
        MessageBool *b = proto_reply.MutableExtension(MessageBool::Bool);
        b->set_successfull(true);

        
        int size = proto_reply.ByteSize();
        char* bytes = new char[size];
        try
        {
            proto_reply.SerializeToArray(bytes, size);
        }
        catch (google::protobuf::FatalException fe)
        {
            std::cout << "ERROR: " << fe.message() << std::endl;
        }
        zmq::message_t reply(size);
        
        memcpy(reply.data(), bytes, size);

        zmq::context_t ct(2);
        zmq::socket_t st(ct, ZMQ_REQ);
        st.connect("tcp://127.0.0.1:5554");
        try
        {
            st.send(reply);
        }
        catch (const zmq::error_t ze)
        {
            std::cout << "Exception: " << ze.what() << std::endl;
        }

    socket.close();
    st.close();
    context.close();
    ct.close();
    
    delete b;
    delete[] bytes;
    //system("pause");

    return 0;
}