f1x1t/myxlib
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: f1x1t:c321076f9656dd0b263e9a3fce7f394015726d8d
Branches Tags
f1x1t:master
f1x1t:myx-cmake
..
compare: f1x1t:c1740b2223635d7500e5e034d47a3ca9178d1c5a
Branches Tags
f1x1t:myx-cmake
f1x1t:master

3 Commits
c321076f96 ... c1740b2223

Author SHA1 Message Date
Andrey Astafyev
c1740b2223 Пример клиента для Redis 2020-04-26 20:42:43 +03:00
Andrey Astafyev
63cd7ff613 Орфография 2020-04-26 20:07:03 +03:00
Andrey Astafyev
14b9c97bb2 Исправлены ошибки компоновки 2020-04-26 19:52:20 +03:00
11 changed files with 111 additions and 158 deletions
Show Stats Expand all files Collapse all files

2
CMakeLists.txt
View File

@ -50,7 +50,7 @@ add_subdirectory(src/myx/redis)
if(MYXLIB_BUILD_EXAMPLES OR MYXLIB_BUILD_EXAMPLES_HO) if(MYXLIB_BUILD_EXAMPLES OR MYXLIB_BUILD_EXAMPLES_HO)
add_subdirectory(examples/filesystem) add_subdirectory(examples/filesystem)
add_subdirectory(examples/qt) add_subdirectory(examples/qt)
# add_subdirectory(examples/redis) add_subdirectory(examples/redis)
endif() endif()
# Документация # Документация

89
examples/redis.old/01_client/client.hpp
View File

@ -1,89 +0,0 @@
#include <QObject>
#include <QDebug>
#include <myx/redis/client.hpp>
namespace MR = myx::redis;
class RedisClient : public QObject
{
Q_OBJECT
MR::Client m_client;
MR::Client m_subscribe;
MR::Request* m_request;
MR::Request* m_channel;
public:
RedisClient( QObject* parent = nullptr ) :
QObject( parent )
{
connect( &m_client, &MR::Client::connected, this, &RedisClient::slotConnected );
connect( &m_subscribe, &MR::Client::connected, this, &RedisClient::slotStartSubscribe );
m_client.connectToHost( "127.0.0.1" );
m_subscribe.connectToHost( "127.0.0.1" );
}
virtual ~RedisClient() {}
Q_SLOT void slotStartSubscribe()
{
m_channel = m_subscribe.subscribeToChannel( "test" );
connect( m_channel, &MR::Request::reply, this, &RedisClient::slotSubscribeTest );
}
Q_SLOT void slotSubscribeTest( MR::Reply reply )
{
qDebug() << static_cast< int >( reply.type() );
auto& v = reply.value();
if ( !v.canConvert< QVariantList >() ) { return; }
auto l = v.toList();
for ( auto& a: l )
{
qDebug() << a.value< MR::Reply >().value().toByteArray();
}
}
Q_SLOT void slotConnected()
{
m_request = m_client.sendCommand( "PING" );
connect( m_request, &MR::Request::reply, this, &RedisClient::slotPong );
}
Q_SLOT void slotPong( MR::Reply reply )
{
qDebug() << static_cast< int >( reply.type() );
qDebug() << reply.value().toString();
m_request->disconnect();
m_request->deleteLater();
m_request = m_client.sendCommand( "SET value 10" );
connect( m_request, &MR::Request::reply, this, &RedisClient::slotSetValue );
}
Q_SLOT void slotSetValue( MR::Reply reply )
{
qDebug() << static_cast< int >( reply.type() );
qDebug() << reply.value().toString();
m_request->disconnect();
m_request->deleteLater();
m_request = m_client.sendCommand( "GET value" );
connect( m_request, &MR::Request::reply, this, &RedisClient::slotGetValue );
}
Q_SLOT void slotGetValue( MR::Reply reply )
{
qDebug() << static_cast< int >( reply.type() );
qDebug() << reply.value().toByteArray();
m_request->disconnect();
m_request->deleteLater();
}
}; // class RedisClient

5
examples/redis.old/01_client/CMakeLists.txt → examples/redis/01_client/CMakeLists.txt
View File

@ -60,8 +60,9 @@ endif()
if(MYXLIB_BUILD_EXAMPLES_HO) if(MYXLIB_BUILD_EXAMPLES_HO)
set(REDIS_LIB_DIR ${CMAKE_SOURCE_DIR}/src/myx/redis) set(REDIS_LIB_DIR ${CMAKE_SOURCE_DIR}/src/myx/redis)
set(REDIS_moc_hpp ${REDIS_LIB_DIR}/client.hpp ${REDIS_LIB_DIR}/lexer.hpp ${REDIS_LIB_DIR}/parser.hpp set(REDIS_moc_hpp ${REDIS_LIB_DIR}/base.hpp
${REDIS_LIB_DIR}/request.hpp) ${REDIS_LIB_DIR}/containers.hpp
${REDIS_LIB_DIR}/pubsub.hpp)
qt5_wrap_cpp(REDIS_moc_cpp ${REDIS_moc_hpp}) qt5_wrap_cpp(REDIS_moc_cpp ${REDIS_moc_hpp})

9
examples/redis.old/01_client/client.cpp → examples/redis/01_client/client.cpp
View File

@ -1,12 +1,19 @@
#include "client.hpp" #include "client.hpp"
#include <myx/redis/pubsub.hpp>
#include <QCoreApplication> #include <QCoreApplication>
#include <QDebug> #include <QDebug>
namespace MR = myx::redis;
int main( int argc, char** argv ) int main( int argc, char** argv )
{ {
QCoreApplication app( argc, argv ); QCoreApplication app( argc, argv );
RedisClient client;
MR::PubSub a;
RedisClient c( &a );
a.start();
return( QCoreApplication::exec() ); return( QCoreApplication::exec() );
} // main } // main

32
examples/redis/01_client/client.hpp Normal file
View File

@ -0,0 +1,32 @@
#include <QObject>
#include <QDebug>
#include <myx/redis/pubsub.hpp>
namespace MR = myx::redis;
class RedisClient : public QObject
{
Q_OBJECT
public:
explicit RedisClient( MR::PubSub* p, QObject* o = nullptr ) :
QObject( o )
{
p->subscribe( "test", this, "readChannelTest" );
}
private:
Q_INVOKABLE void readChannelTest( const QString& channel, const QByteArray& message )
{
qDebug() << channel;
qDebug() << message;
if ( message == "quit" )
{
qCritical() << message;
qApp->quit();
}
}
}; // class RedisClient

0
examples/redis.old/CMakeLists.txt → examples/redis/CMakeLists.txt
View File

4
src/myx/base/config.hpp
View File

@ -15,11 +15,9 @@
#else #else
#define MYXLIB_API #define MYXLIB_API
#endif #endif
#define MYXLIB_INLINE inline // NOLINT #define MYXLIB_INLINE
#else #else
#ifndef MYXLIB_HEADER_ONLY
#define MYXLIB_HEADER_ONLY #define MYXLIB_HEADER_ONLY
#endif
#define MYXLIB_API #define MYXLIB_API
#define MYXLIB_INLINE inline #define MYXLIB_INLINE inline
#endif // ifdef MYXLIB_BUILD_LIBRARIES #endif // ifdef MYXLIB_BUILD_LIBRARIES

28
src/myx/redis/base-inl.hpp
View File

@ -16,12 +16,12 @@ namespace myx {
namespace redis { namespace redis {
/*! /*!
* \brief Создает объект класса * \brief Создаёт объект класса
* \param host Имя хоста сервера * \param host Имя хоста сервера
* \param port Номер порта сервера * \param port Номер порта сервера
* \param parent Родительский объект * \param parent Родительский объект
*/ */
inline Base::Base( QObject* parent ) : MYXLIB_INLINE Base::Base( QObject* parent ) :
QObject { parent }, QObject { parent },
m_readTimer ( new QTimer( this ) ), m_readTimer ( new QTimer( this ) ),
m_writeTimer( new QTimer( this ) ) m_writeTimer( new QTimer( this ) )
@ -47,47 +47,47 @@ inline Base::Base( QObject* parent ) :
} }
inline int Base::rwTimeout() const MYXLIB_INLINE int Base::rwTimeout() const
{ {
return( kRWTimeout ); return( kRWTimeout );
} }
inline QString Base::host() const MYXLIB_INLINE QString Base::host() const
{ {
return( m_host ); return( m_host );
} }
/*! /*!
* \brief Задает адрес хоста * \brief Задаёт адрес хоста
* \param host Адрес * \param host Адрес
*/ */
inline void Base::setHost( const QString& host ) MYXLIB_INLINE void Base::setHost( const QString& host )
{ {
m_host = host; m_host = host;
} }
inline quint16 Base::port() const MYXLIB_INLINE quint16 Base::port() const
{ {
return( m_port ); return( m_port );
} }
inline void Base::setPort( quint16 port ) MYXLIB_INLINE void Base::setPort( quint16 port )
{ {
m_port = port; m_port = port;
} }
inline int Base::connectionFlags() const MYXLIB_INLINE int Base::connectionFlags() const
{ {
return( m_connectionFlags ); return( m_connectionFlags );
} }
inline void Base::setConnectionFlags( int connectionFlags ) MYXLIB_INLINE void Base::setConnectionFlags( int connectionFlags )
{ {
m_connectionFlags = connectionFlags; m_connectionFlags = connectionFlags;
} }
@ -97,7 +97,7 @@ inline void Base::setConnectionFlags( int connectionFlags )
* \brief Возвращает признак установленного соединения * \brief Возвращает признак установленного соединения
* \return Признак установленного соединения * \return Признак установленного соединения
*/ */
inline bool Base::isConnected() const MYXLIB_INLINE bool Base::isConnected() const
{ {
return( ( m_connectionFlags & kConnected ) != 0 ); return( ( m_connectionFlags & kConnected ) != 0 );
} }
@ -106,7 +106,7 @@ inline bool Base::isConnected() const
/*! /*!
* \brief Добавляет к состоянию флаг Read * \brief Добавляет к состоянию флаг Read
*/ */
inline void Base::onReadyRead() MYXLIB_INLINE void Base::onReadyRead()
{ {
if ( ( ( m_connectionFlags & kConnected ) != 0 ) && ( ( m_connectionFlags & kRead ) == 0 ) ) if ( ( ( m_connectionFlags & kConnected ) != 0 ) && ( ( m_connectionFlags & kRead ) == 0 ) )
{ {
@ -120,7 +120,7 @@ inline void Base::onReadyRead()
/*! /*!
* \brief Добавляет к состоянию флаг Read * \brief Добавляет к состоянию флаг Read
*/ */
inline void Base::onBytesWritten() MYXLIB_INLINE void Base::onBytesWritten()
{ {
if ( ( ( m_connectionFlags & kConnected ) != 0 ) && ( ( m_connectionFlags & kWrite ) == 0 ) ) if ( ( ( m_connectionFlags & kConnected ) != 0 ) && ( ( m_connectionFlags & kWrite ) == 0 ) )
{ {
@ -134,7 +134,7 @@ inline void Base::onBytesWritten()
/*! /*!
* \brief Выставляет флаг ошибки соединения * \brief Выставляет флаг ошибки соединения
*/ */
inline void Base::onSocketError() MYXLIB_INLINE void Base::onSocketError()
{ {
Q_EMIT connectionStateChanged( m_connectionFlags = kError ); Q_EMIT connectionStateChanged( m_connectionFlags = kError );
} }

22
src/myx/redis/containers-inl.hpp
View File

@ -23,11 +23,11 @@ static const QByteArray Separator { "\r\n" }; //!< Строковый разде
namespace C = constants; namespace C = constants;
/*! /*!
* \brief Создает часть команды * \brief Создаёт часть команды
* \param value Значение для создани части команды * \param value Значение для создании части команды
* \return Часть команды * \return Часть команды
*/ */
inline QByteArray part( const QVariant& value ) MYXLIB_INLINE QByteArray part( const QVariant& value )
{ {
auto bytes = value.toByteArray(); auto bytes = value.toByteArray();
return( "$" + QByteArray::number( bytes.length() ) + C::Separator + bytes ); return( "$" + QByteArray::number( bytes.length() ) + C::Separator + bytes );
@ -39,7 +39,7 @@ inline QByteArray part( const QVariant& value )
* \param parts Части для составления массива * \param parts Части для составления массива
* \return RESP массив * \return RESP массив
*/ */
inline QByteArray array( const QVariantList& parts ) MYXLIB_INLINE QByteArray array( const QVariantList& parts )
{ {
QByteArrayList data; QByteArrayList data;
std::transform( parts.cbegin(), parts.cend(), std::back_inserter( data ), std::transform( parts.cbegin(), parts.cend(), std::back_inserter( data ),
@ -52,10 +52,10 @@ inline QByteArray array( const QVariantList& parts )
/*! /*!
* \brief Разбивает буфер данных на массив частей * \brief Разбивает буфер данных на массив частей
* \param buffer Входной буфер данных * \param buffer Входной буфер данных
* \param splitLength Длина разобранной части буффера * \param splitLength Длина разобранной части буфера
* \return Массив частей-строк * \return Массив частей-строк
*/ */
inline QByteArrayList split( const QByteArray& buffer, int* splitLength ) MYXLIB_INLINE QByteArrayList split( const QByteArray& buffer, int* splitLength )
{ {
enum Token enum Token
{ {
@ -173,7 +173,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
} }
} // switch } // switch
} }
// может быть ситуация, когда в буфер недочитан последний \r\n, // может быть ситуация, когда в буфер не дочитан последний \r\n,
// но все части были вычитаны // но все части были вычитаны
if ( ( parts.size() == size ) && ( pos <= buffer.length() ) ) if ( ( parts.size() == size ) && ( pos <= buffer.length() ) )
{ {
@ -192,7 +192,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
* \param hash Таблица значений * \param hash Таблица значений
* \return Запакованное сообщение * \return Запакованное сообщение
*/ */
inline QByteArray pack_hash( const QVariantHash& hash ) MYXLIB_INLINE QByteArray pack_hash( const QVariantHash& hash )
{ {
QVariantList parts; QVariantList parts;
for ( auto iter = hash.cbegin(); iter != hash.cend(); ++iter ) for ( auto iter = hash.cbegin(); iter != hash.cend(); ++iter )
@ -208,7 +208,7 @@ inline QByteArray pack_hash( const QVariantHash& hash )
* \param message Сообщение * \param message Сообщение
* \return Таблица значений * \return Таблица значений
*/ */
inline QVariantHash unpack_hash( const QByteArray& message ) MYXLIB_INLINE QVariantHash unpack_hash( const QByteArray& message )
{ {
auto parts = split( message ); auto parts = split( message );
QVariantHash hash; QVariantHash hash;
@ -225,7 +225,7 @@ inline QVariantHash unpack_hash( const QByteArray& message )
* \param hash Список значений * \param hash Список значений
* \return Запакованное сообщение * \return Запакованное сообщение
*/ */
inline QByteArray pack_list( const QVariantList& list ) MYXLIB_INLINE QByteArray pack_list( const QVariantList& list )
{ {
return( array( list ) ); return( array( list ) );
} }
@ -236,7 +236,7 @@ inline QByteArray pack_list( const QVariantList& list )
* \param message Сообщение * \param message Сообщение
* \return Список значений * \return Список значений
*/ */
inline QVariantList unpack_list( const QByteArray& message ) MYXLIB_INLINE QVariantList unpack_list( const QByteArray& message )
{ {
auto data = split( message ); auto data = split( message );
QVariantList list; QVariantList list;

63
src/myx/redis/pubsub-inl.hpp
View File

@ -19,13 +19,11 @@ namespace myx {
namespace redis { namespace redis {
const QString PubSub::kKeySpacePrefix { QStringLiteral( "__key%1__:" ) };
/*! /*!
* \brief Конструктор класса * \brief Конструктор класса
* \param parent Родительский объект для m_socket * \param parent Родительский объект для m_socket
*/ */
inline PubSub::PubSub( QObject* parent ) : MYXLIB_INLINE PubSub::PubSub( QObject* parent ) :
Base { parent }, Base { parent },
m_socket ( new QTcpSocket( this ) ), m_socket ( new QTcpSocket( this ) ),
m_connectionTimer( new QTimer( this ) ) m_connectionTimer( new QTimer( this ) )
@ -49,7 +47,7 @@ inline PubSub::PubSub( QObject* parent ) :
} }
inline int PubSub::connectionTimeout() const MYXLIB_INLINE int PubSub::connectionTimeout() const
{ {
return( kConnectionTimeout ); return( kConnectionTimeout );
} }
@ -58,7 +56,7 @@ inline int PubSub::connectionTimeout() const
/*! /*!
* \brief Инициирует работу с БД * \brief Инициирует работу с БД
*/ */
inline void PubSub::start() MYXLIB_INLINE void PubSub::start()
{ {
Q_EMIT disconnected(); Q_EMIT disconnected();
Q_EMIT connectionStateChanged( connectionFlags() ); Q_EMIT connectionStateChanged( connectionFlags() );
@ -69,7 +67,7 @@ inline void PubSub::start()
/*! /*!
* \brief Завершает работу с БД * \brief Завершает работу с БД
*/ */
inline void PubSub::stop() MYXLIB_INLINE void PubSub::stop()
{ {
if ( m_socket->state() == QAbstractSocket::ConnectedState ) if ( m_socket->state() == QAbstractSocket::ConnectedState )
{ {
@ -83,12 +81,12 @@ inline void PubSub::stop()
/*! /*!
* \brief Создает подписку на канал сообщений * \brief Создаёт подписку на канал сообщений
* \param channel Rанал подписки * \param channel Канал подписки
* \param subscriber Объект-подписчик * \param subscriber Объект-подписчик
* \param method Имя метода, вызываемого при изменении получении серверного сообщения * \param method Имя метода, вызываемого при изменении получении серверного сообщения
*/ */
inline void PubSub::subscribe( const QString& channel, QObject* subscriber, const char* method ) MYXLIB_INLINE void PubSub::subscribe( const QString& channel, QObject* subscriber, const char* method )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
{ {
@ -122,13 +120,13 @@ inline void PubSub::subscribe( const QString& channel, QObject* subscriber, cons
/*! /*!
* \brief Создает подписку на канал изменения данных * \brief Создаёт подписку на канал изменения данных
* \param channel Rанал подписки * \param channel Канал подписки
* \param subscriber Объект-подписчик * \param subscriber Объект-подписчик
* \param method Имя метода, вызываемого при изменении получении серверного сообщения * \param method Имя метода, вызываемого при изменении получении серверного сообщения
* \param database Номер БД * \param database Номер БД
*/ */
inline void PubSub::subscribe( QString channel, QObject* subscriber, const char* method, int database ) MYXLIB_INLINE void PubSub::subscribe( QString channel, QObject* subscriber, const char* method, int database )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
{ {
@ -138,7 +136,7 @@ inline void PubSub::subscribe( QString channel, QObject* subscriber, const char*
auto iter = m_subscribers.find( channel ); auto iter = m_subscribers.find( channel );
if ( iter == m_subscribers.end() ) if ( iter == m_subscribers.end() )
{ {
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
if ( m_socket->state() == QAbstractSocket::ConnectedState ) if ( m_socket->state() == QAbstractSocket::ConnectedState )
{ {
m_socket->write( array( { "SUBSCRIBE", channel } ) ); m_socket->write( array( { "SUBSCRIBE", channel } ) );
@ -163,12 +161,12 @@ inline void PubSub::subscribe( QString channel, QObject* subscriber, const char*
/*! /*!
* \brief Создает подписку на шаблон канала сообщений * \brief Создаёт подписку на шаблон канала сообщений
* \param channel Шаблон канала подписки * \param channel Шаблон канала подписки
* \param subscriber Объект-подписчик * \param subscriber Объект-подписчик
* \param method Имя метода, вызываемого при изменении получении серверного сообщения * \param method Имя метода, вызываемого при изменении получении серверного сообщения
*/ */
inline void PubSub::psubscribe( const QString& channel, QObject* subscriber, const char* method ) MYXLIB_INLINE void PubSub::psubscribe( const QString& channel, QObject* subscriber, const char* method )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
{ {
@ -202,13 +200,13 @@ inline void PubSub::psubscribe( const QString& channel, QObject* subscriber, con
/*! /*!
* \brief Создает подписку на шаблон канала изменения данных * \brief Создаёт подписку на шаблон канала изменения данных
* \param channel Шаблон канала подписки * \param channel Шаблон канала подписки
* \param subscriber Объект-подписчик * \param subscriber Объект-подписчик
* \param method Имя метода, вызываемого при изменении получении серверного сообщения * \param method Имя метода, вызываемого при изменении получении серверного сообщения
* \param database Номер БД (-1 для всех) * \param database Номер БД (-1 для всех)
*/ */
inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char* method, int database ) MYXLIB_INLINE void PubSub::psubscribe( QString channel, QObject* subscriber, const char* method, int database )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
{ {
@ -220,11 +218,11 @@ inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char
{ {
if ( database == -1 ) if ( database == -1 )
{ {
channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
} }
else else
{ {
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
} }
if ( m_socket->state() == QAbstractSocket::ConnectedState ) if ( m_socket->state() == QAbstractSocket::ConnectedState )
{ {
@ -256,7 +254,7 @@ inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char
* \param method Метод обработки данных * \param method Метод обработки данных
* \param keyEvents Признак подписки на изменение данных * \param keyEvents Признак подписки на изменение данных
*/ */
inline void PubSub::unsubscribe( const QString& channel, QObject* subscriber, const char* method ) MYXLIB_INLINE void PubSub::unsubscribe( const QString& channel, QObject* subscriber, const char* method )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
{ {
@ -293,7 +291,7 @@ inline void PubSub::unsubscribe( const QString& channel, QObject* subscriber, co
* \param method Метод обработки данных * \param method Метод обработки данных
* \param keyEvents Признак подписки на изменение данных * \param keyEvents Признак подписки на изменение данных
*/ */
inline void PubSub::unsubscribe( QString channel, QObject* subscriber, const char* method, int database ) MYXLIB_INLINE void PubSub::unsubscribe( QString channel, QObject* subscriber, const char* method, int database )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
{ {
@ -302,11 +300,11 @@ inline void PubSub::unsubscribe( QString channel, QObject* subscriber, const cha
} }
if ( database == -1 ) if ( database == -1 )
{ {
channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
} }
else else
{ {
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
} }
auto iter = m_subscribers.find( channel ); auto iter = m_subscribers.find( channel );
if ( iter != m_subscribers.end() ) if ( iter != m_subscribers.end() )
@ -338,7 +336,7 @@ inline void PubSub::unsubscribe( QString channel, QObject* subscriber, const cha
* \param method Метод обработки данных * \param method Метод обработки данных
* \param keyEvents Признак подписки на изменение данных * \param keyEvents Признак подписки на изменение данных
*/ */
inline void PubSub::punsubscribe( const QString& channel, QObject* subscriber, MYXLIB_INLINE void PubSub::punsubscribe( const QString& channel, QObject* subscriber,
const char* method ) const char* method )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
@ -376,7 +374,7 @@ inline void PubSub::punsubscribe( const QString& channel, QObject* subscriber,
* \param method Метод обработки данных * \param method Метод обработки данных
* \param keyEvents Признак подписки на изменение данных * \param keyEvents Признак подписки на изменение данных
*/ */
inline void PubSub::punsubscribe( QString channel, QObject* subscriber, MYXLIB_INLINE void PubSub::punsubscribe( QString channel, QObject* subscriber,
const char* method, int database ) const char* method, int database )
{ {
if ( QThread::currentThread() != thread() ) if ( QThread::currentThread() != thread() )
@ -386,11 +384,11 @@ inline void PubSub::punsubscribe( QString channel, QObject* subscriber,
} }
if ( database == -1 ) if ( database == -1 )
{ {
channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
} }
else else
{ {
channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() ); channel.prepend( C::KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
} }
auto iter = m_psubscribers.find( channel ); auto iter = m_psubscribers.find( channel );
if ( iter != m_psubscribers.end() ) if ( iter != m_psubscribers.end() )
@ -419,7 +417,7 @@ inline void PubSub::punsubscribe( QString channel, QObject* subscriber,
* \brief Разбирает поступившие от сервера уведомления и вызывает требуемые * \brief Разбирает поступившие от сервера уведомления и вызывает требуемые
* метаметоды обработки * метаметоды обработки
*/ */
inline void PubSub::read() MYXLIB_INLINE void PubSub::read()
{ {
int splitLength = 0; int splitLength = 0;
while ( m_socket->bytesAvailable() > 0 ) while ( m_socket->bytesAvailable() > 0 )
@ -470,7 +468,7 @@ inline void PubSub::read()
/*! /*!
* \brief Обработка изменения состояния сокета * \brief Обработка изменения состояния сокета
*/ */
inline void PubSub::onSocketStateChanged() MYXLIB_INLINE void PubSub::onSocketStateChanged()
{ {
switch ( m_socket->state() ) switch ( m_socket->state() )
{ {
@ -505,9 +503,9 @@ inline void PubSub::onSocketStateChanged()
/*! /*!
* \brief При удалении подписчика уничтожает все его подписки * \brief При удалении подписчика уничтожает все его подписки
* \param subscriber Удаленный подписчик * \param subscriber Удалённый подписчик
*/ */
inline void PubSub::onSubscriberDestroyed( QObject* subscriber ) MYXLIB_INLINE void PubSub::onSubscriberDestroyed( QObject* subscriber )
{ {
for ( auto i = m_subscribers.begin(); i != m_subscribers.end(); ) for ( auto i = m_subscribers.begin(); i != m_subscribers.end(); )
{ {
@ -569,7 +567,7 @@ inline void PubSub::onSubscriberDestroyed( QObject* subscriber )
* \brief Возвращает сокет * \brief Возвращает сокет
* \return Сокет * \return Сокет
*/ */
inline QTcpSocket* PubSub::socket() const MYXLIB_INLINE QTcpSocket* PubSub::socket() const
{ {
return( m_socket ); return( m_socket );
} }
@ -578,5 +576,4 @@ inline QTcpSocket* PubSub::socket() const
} // namespace myx } // namespace myx
#endif // ifndef MYX_REDIS_PUBSUB_INL_HPP_ #endif // ifndef MYX_REDIS_PUBSUB_INL_HPP_

11
src/myx/redis/pubsub.hpp
View File

@ -13,10 +13,18 @@ namespace myx {
namespace redis { namespace redis {
namespace constants {
/// @brief Приставка для наблюдения за данными
static const QString KeySpacePrefix { QStringLiteral( "__key%1__:" ) };
} // namespace constants
namespace C = constants;
/*! /*!
* \brief Управляет подпиской и публикацией сообщений * \brief Управляет подпиской и публикацией сообщений
*/ */
class PubSub : public Base class PubSub : public Base
{ {
Q_OBJECT Q_OBJECT
@ -52,7 +60,6 @@ public:
private: private:
using Sub = QHash< QString, std::vector< std::pair< QObject*, const char* > > >; using Sub = QHash< QString, std::vector< std::pair< QObject*, const char* > > >;
static const QString kKeySpacePrefix; //!< Приставка для наблюдения за данными
static constexpr int kConnectionTimeout { 2000 }; //!< Таймаут на сетевые операции static constexpr int kConnectionTimeout { 2000 }; //!< Таймаут на сетевые операции
QTcpSocket* m_socket; QTcpSocket* m_socket;
QTimer* m_connectionTimer; //!< Таймер установления сетевого соединения QTimer* m_connectionTimer; //!< Таймер установления сетевого соединения