Qt & gRPC

 
QT -= gui
CONFIG += c++11 console
CONFIG -= app_bundle
QT += network
LIBS += `pkg-config --libs protobuf grpc++` -lgrpc++_reflection
DEFINES += QT_DEPRECATED_WARNINGS
SOURCES += main.cpp \
    helloworld.pb.cc \
    helloworld.grpc.pb.cc
HEADERS += \
    helloworld.pb.h \
    helloworld.grpc.pb.h

void RunServer() {
  std::string server_address("0.0.0.0:50051");
  GreeterServiceImpl service;
  grpc::EnableDefaultHealthCheckService(true);
  grpc::reflection::InitProtoReflectionServerBuilderPlugin();
  ServerBuilder builder;
  builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
  builder.RegisterService(&service);
  std::unique_ptr<Server> server(builder.BuildAndStart());
  std::cout << "Server listening on " << server_address << std::endl;
  server->Wait();
}

int main(int argc, char** argv) {
  QCoreApplication a(argc, argv);
  RunServer();
  return a.exec();
}

class GreeterServiceImpl final : public QObject, public Greeter::Service {
Q_OBJECT
public:
  explicit GreeterServiceImpl(QObject *parent=nullptr);
  Status SayHello(ServerContext* context, const HelloRequest* request,  HelloReply* reply);
signals:
   void message();
};

class MySslSock
{
public:
    MySslSock();
public slots:
    void setMesaage();
};

MySslSock sock;
QObject::connect(&service, &GreeterServiceImpl::message, &sock, &MySslSock::setMesaage);

In file included from /usr/include/x86_64-linux-gnu/qt5/QtCore/QObject:1:0,
                 from greeterserviceimpl.h:4,
                 from main.cpp:19:
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject.h: In instantiation of ‘static QMetaObject::Connection QObject::connect(const typename QtPrivate::FunctionPointer<Func>::Object*, Func1, const typename QtPrivate::FunctionPointer<Func2>::Object*, Func2, Qt::ConnectionType) [with Func1 = void (GreeterServiceImpl::*)(); Func2 = void (MySslSock::*)(); typename QtPrivate::FunctionPointer<Func>::Object = GreeterServiceImpl; typename QtPrivate::FunctionPointer<Func2>::Object = MySslSock]’:
main.cpp:40:89:   required from here
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject.h:256:27: error: no matching function for call to ‘QObject::connectImpl(const Object*&, void**, const Object*&, void**, QtPrivate::QSlotObject<void (MySslSock::*)(), QtPrivate::List<>, void>*, Qt::ConnectionType&, const int*&, const QMetaObject*)’
         return connectImpl(sender, reinterpret_cast<void **>(&signal),
                ~~~~~~~~~~~^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
                            receiver, reinterpret_cast<void **>(&slot),
                            ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
                            new QtPrivate::QSlotObject<Func2, typename QtPrivate::List_Left<typename SignalType::Arguments, SlotType::ArgumentCount>::Value,
                            ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
                                            typename SignalType::ReturnType>(slot),
                                            ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
                             type, types, &SignalType::Object::staticMetaObject);
                             ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject.h:459:36: note: candidate: static QMetaObject::Connection QObject::connectImpl(const QObject*, void**, const QObject*, void**, QtPrivate::QSlotObjectBase*, Qt::ConnectionType, const int*, const QMetaObject*)
     static QMetaObject::Connection connectImpl(const QObject *sender, void **signal,
                                    ^~~~~~~~~~~
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject.h:459:36: note:   no known conversion for argument 3 from ‘const Object* {aka const MySslSock*}’ to ‘const QObject*’
In file included from /usr/include/x86_64-linux-gnu/qt5/QtCore/qobject.h:56:0,
                 from /usr/include/x86_64-linux-gnu/qt5/QtCore/QObject:1,
                 from greeterserviceimpl.h:4,
                 from main.cpp:19:
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject_impl.h: In instantiation of ‘static void QtPrivate::QSlotObject<Func, Args, R>::impl(int, QtPrivate::QSlotObjectBase*, QObject*, void**, bool*) [with Func = void (MySslSock::*)(); Args = QtPrivate::List<>; R = void]’:
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject_impl.h:129:56:   required from ‘QtPrivate::QSlotObject<Func, Args, R>::QSlotObject(Func) [with Func = void (MySslSock::*)(); Args = QtPrivate::List<>; R = void]’
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject.h:258:28:   required from ‘static QMetaObject::Connection QObject::connect(const typename QtPrivate::FunctionPointer<Func>::Object*, Func1, const typename QtPrivate::FunctionPointer<Func2>::Object*, Func2, Qt::ConnectionType) [with Func1 = void (GreeterServiceImpl::*)(); Func2 = void (MySslSock::*)(); typename QtPrivate::FunctionPointer<Func>::Object = GreeterServiceImpl; typename QtPrivate::FunctionPointer<Func2>::Object = MySslSock]’
main.cpp:40:89:   required from here
/usr/include/x86_64-linux-gnu/qt5/QtCore/qobject_impl.h:120:94: error: invalid static_cast from type ‘QObject*’ to type ‘QtPrivate::FunctionPointer<void (MySslSock::*)()>::Object* {aka MySslSock*}’
                 FuncType::template call<Args, R>(static_cast<QSlotObject*>(this_)->function, static_cast<typename FuncType::Object *>(r), a);
                                                                                              ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Makefile:376: recipe for target 'main.o' failed
make: *** [main.o] Error 1

$ cat mysslsock.h 
#ifndef MYSSLSOCK_H
#define MYSSLSOCK_H

#include <QObject>
#include <QSslSocket>
#include <QSslConfiguration>

class MySslSock: public QObject
{
Q_OBJECT
public:
    explicit MySslSock(QObject *parent=nullptr);
public slots:
    void setMesaage();
};

#endif // MYSSLSOCK_H

r$ cat mysslsock.cpp 
#include "mysslsock.h"

#include <iostream>

MySslSock::MySslSock(QObject* parent)
    : QObject(parent)
{
}

void MySslSock::setMesaage()
{
    std::cout << "send" << std::endl;
    QSslSocket mSocket;
    QSslConfiguration config = mSocket.sslConfiguration();
    config.setPeerVerifyMode(QSslSocket::VerifyNone);
    config.setProtocol(QSsl::SecureProtocols);
    mSocket.setSslConfiguration(config);
    mSocket.connectToHostEncrypted("google.com", 8080);
}

$ cat greeterserviceimpl.h 
#ifndef GREETERSERVICEIMPL_H
#define GREETERSERVICEIMPL_H

#include <QObject>

#include <QCoreApplication>
#include <iostream>
#include <memory>
#include <string>

#include <grpcpp/grpcpp.h>
#include <grpcpp/health_check_service_interface.h>
#include <grpcpp/ext/proto_server_reflection_plugin.h>

#include "helloworld.grpc.pb.h"
#include "mysslsock.h"

#include <QObject>
#include <QSslSocket>
#include <QSslConfiguration>

using grpc::Server;
using grpc::ServerBuilder;
using grpc::ServerContext;
using grpc::Status;
using helloworld::HelloRequest;
using helloworld::HelloReply;
using helloworld::Greeter;

class GreeterServiceImpl final : public QObject, public Greeter::Service {
Q_OBJECT

public:
  explicit GreeterServiceImpl(QObject *parent=nullptr);
  Status SayHello(ServerContext* context, const HelloRequest* request,  HelloReply* reply);
  //Greeter::Service service;

  MySslSock sock;

signals:
   void message();

};

#endif // GREETERSERVICEIMPL_H



$ cat greeterserviceimpl.cpp
#include "greeterserviceimpl.h"


#include <QDebug>

GreeterServiceImpl::GreeterServiceImpl(QObject *parent) : QObject(parent)
{
    //MySslSock sock;
    connect(this, &GreeterServiceImpl::message, &sock, &MySslSock::setMesaage);

}

Status GreeterServiceImpl::SayHello(ServerContext* context, const HelloRequest* request,  HelloReply* reply)
{
    std::string prefix("Hello ");
    reply->set_message(prefix + request->name());

    std::cout << "emit" << std::endl;
    emit message();
    return Status::OK;
}

$ cat main.cpp 
#include "greeterserviceimpl.h"
#include "mysslsock.h"
#include <thread>

void RunServer() {
  std::string server_address("0.0.0.0:50051");
  GreeterServiceImpl service;
  grpc::EnableDefaultHealthCheckService(true);
  grpc::reflection::InitProtoReflectionServerBuilderPlugin();
  ServerBuilder builder;
  builder.AddListeningPort(server_address, grpc::InsecureServerCredentials());
  builder.RegisterService(&service);
  std::unique_ptr<Server> server(builder.BuildAndStart());
  std::cout << "Server listening on " << server_address << std::endl;
  server->Wait();

}

int main(int argc, char** argv) {
  QCoreApplication a(argc, argv);
  std::thread t  (
       []
       {
            RunServer();
       }
  );
  t.detach();
  return a.exec();
}

$ cat server.pro
QT -= gui

CONFIG += c++11 console
CONFIG -= app_bundle

QT += network

LIBS += `pkg-config --libs protobuf grpc++` -lgrpc++_reflection

# The following define makes your compiler emit warnings if you use
# any feature of Qt which as been marked deprecated (the exact warnings
# depend on your compiler). Please consult the documentation of the
# deprecated API in order to know how to port your code away from it.
DEFINES += QT_DEPRECATED_WARNINGS

# You can also make your code fail to compile if you use deprecated APIs.
# In order to do so, uncomment the following line.
# You can also select to disable deprecated APIs only up to a certain version of Qt.
#DEFINES += QT_DISABLE_DEPRECATED_BEFORE=0x060000    # disables all the APIs deprecated before Qt 6.0.0

SOURCES += main.cpp \
    helloworld.pb.cc \
    helloworld.grpc.pb.cc \
    greeterserviceimpl.cpp \
    mysslsock.cpp

HEADERS += \
    helloworld.pb.h \
    helloworld.grpc.pb.h \
    greeterserviceimpl.h \
    mysslsock.h

#ifndef GREETERSERVICEIMPL_H
#define GREETERSERVICEIMPL_H

class GreeterServiceImpl final : public Greeter::Service, public QObject {
Q_OBJECT
 public:
  explicit GreeterServiceImpl( QObject *parent = nullptr );
  ~GreeterServiceImpl();
signals:
   void message();
};

#endif //GREETERSERVICEIMPL_H

GreeterServiceImpl::GreeterServiceImpl(QObject *parent) : QObject(parent) {}
GreeterServiceImpl::~GreeterServiceImpl() {}

HEADERS += \
        GreeterServiceImpl.h
SOURCES += \
        GreeterServiceImpl.cpp

class GreeterServiceImpl final : public Greeter::Service, public QObject

class GreeterServiceImpl final : public QObject, public Greeter::Service

int main(int argc, char** argv) {
  QCoreApplication a(argc, argv);
  std::thread t  (
       []
       {
            RunServer();
       }
  );
  t.detach();
  return a.exec();
}

GreeterServiceImpl::GreeterServiceImpl(QObject *parent) : QObject(parent)
{
    connect(this, &GreeterServiceImpl::message, &sock, &MySslSock::onMessage); // не ругается компилятор, все собирается, но соединение не работает, причем молча

}

Status GreeterServiceImpl::SayHello(ServerContext* context, const HelloRequest* request,  HelloReply* reply)
{
    // ...
    emit message();
    return Status::OK;
}