NB: This specific branch was adapted to work with Qt 6.
A Qt C++11 client for the NATS messaging system.
This is a header-only library that depends on Qt. All you have to do is to include a copy of natsclient.h to your
project sources directory, making sure the Qt Network module is properly linking to your application(s). Follow the instructions below according to your project's build system.
In your project's CMakeLists.txt:
# Add Network module
find_package(Qt${QT_VERSION_MAJOR} COMPONENTS Network REQUIRED)
# Add natsclient.h to the project's sources
set(PROJECT_SOURCES
main.cpp
dialog.cpp
dialog.h
dialog.ui
resources.qrc
# ... other source files
# ...
natsclient.h # <--- Add this line
)
# Link Network module
target_link_libraries(MensajeroSMS PRIVATE Qt${QT_VERSION_MAJOR}::Network)
For QMake projects, you need to add the network module to your project-name.pro file (QT += network).
For more information see examples.
#include <QCoreApplication>
#include "natsclient.h"
int main(int argc, char *argv[])
{
QCoreApplication app(argc, argv);
Nats::Client client(&app);
client.connect("127.0.0.1", 4222, [&]
{
// simple subscribe
client.subscribe("foo", [](QString message, QString inbox, QString subject)
{
qDebug() << "received: " << message << inbox << subject;
});
// simple publish
client.publish("foo", "Hello NATS!");
});
return app.exec();
}
Nats::Client client(&parentQObject);
client.connect("127.0.0.1", 4222, [&]
{
// simple publish
client.publish("foo", "Hello World!");
// simple subscribe
client.subscribe("foo", [](QString message, QString /* inbox */, QString /* subject */)
{
qDebug() << "received message: " << message;
});
// unsubscribe
int sid = client.subscribe("foo", [](QString, QString, QString){});
client.unsubscribe(sid);
// request
client.request("help", [&](QString /* message */, QString reply_inbox, QString /* subject */)
{
client.publish(reply_inbox, "I can help");
});
});
All subscriptions with the same queue name will form a queue group. Each message will be delivered to only one subscriber per queue group, queuing semantics. You can have as many queue groups as you wish. Normal subscribers will continue to work as expected.
client.subscribe("foo", "job.workers", [](QString message, QString reply_inbox, QString subject)
{
qDebug().noquote() << "received message:" << message << subject << reply_inbox;
});
Nats::Client client(&parentQObject);
Nats::Options options;
// username/password
options.user = "user";
options.pass = "pass";
client.connect("127.0.0.1", 4222, options, []
{
...
});
// token
options.token = "mytoken";
client.connect("127.0.0.1", 4222, options, []
{
...
});
Nats::Client client(&parentQObject);
Nats::Options options;
// for development
options.ssl_verify = false;
// set relevant ssl options
options.ssl_ca = "/path/to/ca.crt";
options.ssl_key = "/path/to/local.key";
options.ssl_cert = "/path/to/local.crt";
client.connect("127.0.0.1", 4222, options, [&client]
{
...
});
This is Qt specific. If you are used to using Qt signals & slots or you just prefer them over callbacks:
Nats::Client client(&parentQObject);
QObject::connect(&client, &Nats::Client::connected, [&client]
{
Nats::Subscription *s = client.subscribe("foo");
QObject::connect(s, &Nats::Subscription::received, [s]
{
qDebug().noquote() << "received message:" << s->message << s->subject << s->inbox;
s->deleteLater();
});
client.publish("foo", "Hello NATS!");
});
client.connect("127.0.0.1", 4222);
Catch errors:
QObject::connect(&client, &Nats::Client::error, [](const QString &error)
{
qDebug() << error;
});
Catch connection disconnect:
QObject::connect(&client, &Nats::Client::disconnected, []
{
qDebug() << "disconnected";
});
For extra debug information env variable can be used:
export DEBUG=qt-nats
or
DEBUG=qt-nats ./program
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent