Compare commits
3 Commits
36a2a1d2c6
...
71e8dd0202
Author | SHA1 | Date | |
---|---|---|---|
71e8dd0202 | |||
8744da7759 | |||
dd015a3143 |
@ -50,6 +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)
|
||||||
endif()
|
endif()
|
||||||
|
|
||||||
# Документация
|
# Документация
|
||||||
|
82
examples/redis/01_client/CMakeLists.txt
Normal file
82
examples/redis/01_client/CMakeLists.txt
Normal file
@ -0,0 +1,82 @@
|
|||||||
|
# Название основной цели в текущем каталоге
|
||||||
|
set(TRGT example-redis-client)
|
||||||
|
|
||||||
|
# Список файлов исходных текстов
|
||||||
|
set(TRGT_cpp ${CMAKE_CURRENT_SOURCE_DIR}/main.cpp)
|
||||||
|
|
||||||
|
set(TRGT_moc_hpp ${CMAKE_CURRENT_SOURCE_DIR}/client.hpp)
|
||||||
|
|
||||||
|
qt5_wrap_cpp(TRGT_moc_cpp ${TRGT_moc_hpp})
|
||||||
|
|
||||||
|
if(MYXLIB_BUILD_EXAMPLES)
|
||||||
|
|
||||||
|
# Путь поиска библиотек внутри проекта
|
||||||
|
link_directories(${CMAKE_BINARY_DIR}/${CMAKE_INSTALL_LIBDIR})
|
||||||
|
|
||||||
|
# Цель для создания исполняемого файла
|
||||||
|
add_executable(${TRGT} ${TRGT_cpp} ${TRGT_moc_cpp} ${TRGT_moc_hpp})
|
||||||
|
common_target_properties(${TRGT})
|
||||||
|
|
||||||
|
# Создание цели для проверки утилитой clang-tidy
|
||||||
|
add_clang_tidy_check(${TRGT} ${TRGT_cpp})
|
||||||
|
|
||||||
|
# Создание цели для проверки утилитой clang-analyze
|
||||||
|
add_clang_analyze_check(${TRGT} ${TRGT_cpp})
|
||||||
|
|
||||||
|
# Создание цели для проверки утилитой clazy
|
||||||
|
add_clazy_check(${TRGT} ${TRGT_cpp})
|
||||||
|
|
||||||
|
# Создание цели для проверки утилитой pvs-studio
|
||||||
|
add_pvs_check(${TRGT})
|
||||||
|
|
||||||
|
# Создание цели для автоматического форматирования кода
|
||||||
|
add_format_sources(${TRGT} ${TRGT_cpp})
|
||||||
|
|
||||||
|
# Qt5
|
||||||
|
target_include_directories(${TRGT} PRIVATE ${CMAKE_SOURCE_DIR}/src)
|
||||||
|
target_include_directories(${TRGT} SYSTEM PUBLIC ${Qt5Core_INCLUDE_DIRS})
|
||||||
|
target_include_directories(${TRGT} SYSTEM PUBLIC ${Qt5Network_INCLUDE_DIRS})
|
||||||
|
|
||||||
|
target_compile_definitions(${TRGT} PUBLIC MYXLIB_HEADER_ONLY)
|
||||||
|
add_dependencies(${TRGT} base_static redis_static)
|
||||||
|
|
||||||
|
target_link_libraries(${TRGT} myx-redis)
|
||||||
|
target_link_libraries(${TRGT} Qt5::Core Qt5::Network)
|
||||||
|
|
||||||
|
# Имя выходного файла для цели
|
||||||
|
set_target_properties(${TRGT} PROPERTIES OUTPUT_NAME redis-client)
|
||||||
|
|
||||||
|
add_sanitizers(${TRGT})
|
||||||
|
|
||||||
|
cotire(${TRGT})
|
||||||
|
|
||||||
|
add_dependencies(${TRGT} create_auxilary_symlinks)
|
||||||
|
|
||||||
|
# Правила для установки
|
||||||
|
install(TARGETS ${TRGT} COMPONENT examples RUNTIME DESTINATION ${CMAKE_INSTALL_BINDIR})
|
||||||
|
endif()
|
||||||
|
|
||||||
|
if(MYXLIB_BUILD_EXAMPLES_HO)
|
||||||
|
# Цель для создания исполняемого файла
|
||||||
|
add_executable(${TRGT}-ho ${TRGT_cpp} ${TRGT_qrc})
|
||||||
|
common_target_properties(${TRGT}-ho)
|
||||||
|
|
||||||
|
target_include_directories(${TRGT}-ho PRIVATE ${CMAKE_SOURCE_DIR}/src)
|
||||||
|
target_include_directories(${TRGT}-ho SYSTEM PUBLIC ${Qt5Core_INCLUDE_DIRS})
|
||||||
|
|
||||||
|
add_dependencies(${TRGT}-ho base-header-only qt-header-only)
|
||||||
|
|
||||||
|
target_link_libraries(${TRGT}-ho Qt5::Core)
|
||||||
|
target_link_libraries(${TRGT}-ho Threads::Threads)
|
||||||
|
|
||||||
|
# Имя выходного файла для цели
|
||||||
|
set_target_properties(${TRGT}-ho PROPERTIES OUTPUT_NAME qt-translators-ho)
|
||||||
|
|
||||||
|
add_sanitizers(${TRGT}-ho)
|
||||||
|
cotire(${TRGT}-ho)
|
||||||
|
|
||||||
|
add_dependencies(${TRGT}-ho create_auxilary_symlinks)
|
||||||
|
|
||||||
|
# Правила для установки
|
||||||
|
install(TARGETS ${TRGT}-ho COMPONENT examples RUNTIME DESTINATION ${CMAKE_INSTALL_BINDIR})
|
||||||
|
endif()
|
67
examples/redis/01_client/client.hpp
Normal file
67
examples/redis/01_client/client.hpp
Normal file
@ -0,0 +1,67 @@
|
|||||||
|
#include <QObject>
|
||||||
|
#include <QDebug>
|
||||||
|
|
||||||
|
#include <myx/redis/client.hpp>
|
||||||
|
|
||||||
|
namespace MR = myx::redis;
|
||||||
|
|
||||||
|
class RedisClient : public QObject
|
||||||
|
{
|
||||||
|
Q_OBJECT
|
||||||
|
|
||||||
|
MR::Client m_client;
|
||||||
|
MR::Request* m_request;
|
||||||
|
|
||||||
|
public:
|
||||||
|
RedisClient()
|
||||||
|
{
|
||||||
|
connect(&m_client, &MR::Client::connected, this, &RedisClient::slotConnected);
|
||||||
|
m_client.connectToHost("127.0.0.1");
|
||||||
|
|
||||||
|
}
|
||||||
|
virtual ~RedisClient() {}
|
||||||
|
|
||||||
|
Q_SLOT void slotConnected()
|
||||||
|
{
|
||||||
|
m_request = m_client.sendCommand("PING");
|
||||||
|
connect(m_request, &MR::Request::reply, this, &RedisClient::slotPong);
|
||||||
|
}
|
||||||
|
|
||||||
|
Q_SLOT void slotPong( const MR::Reply& reply)
|
||||||
|
{
|
||||||
|
qDebug() << static_cast<int>(reply.type());
|
||||||
|
qDebug() << const_cast<MR::Reply&>(reply).value().toString();
|
||||||
|
m_request->disconnect();
|
||||||
|
m_request->deleteLater();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
Q_SLOT void slotSetValue( const MR::Reply& reply)
|
||||||
|
{
|
||||||
|
qDebug() << static_cast<int>(reply.type());
|
||||||
|
qDebug() << const_cast<MR::Reply&>(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( const MR::Reply& reply)
|
||||||
|
{
|
||||||
|
qDebug() << static_cast<int>(reply.type());
|
||||||
|
qDebug() << const_cast<MR::Reply&>(reply).value().toByteArray();
|
||||||
|
m_request->disconnect();
|
||||||
|
m_request->deleteLater();
|
||||||
|
|
||||||
|
m_request = m_client.sendCommand( "SUBSCRIBE test" );
|
||||||
|
connect(m_request, &MR::Request::reply, this, &RedisClient::slotSubscribeTest);
|
||||||
|
}
|
||||||
|
|
||||||
|
Q_SLOT void slotSubscribeTest( const MR::Reply& reply)
|
||||||
|
{
|
||||||
|
qDebug() << static_cast<int>(reply.type());
|
||||||
|
qDebug() << const_cast<MR::Reply&>(reply).value().toByteArray();
|
||||||
|
}
|
||||||
|
};
|
14
examples/redis/01_client/main.cpp
Normal file
14
examples/redis/01_client/main.cpp
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
#include "client.hpp"
|
||||||
|
|
||||||
|
#include <QCoreApplication>
|
||||||
|
#include <QDebug>
|
||||||
|
|
||||||
|
namespace MR = myx::redis;
|
||||||
|
|
||||||
|
int main( int argc, char** argv )
|
||||||
|
{
|
||||||
|
QCoreApplication app( argc, argv );
|
||||||
|
RedisClient client;
|
||||||
|
|
||||||
|
return( QCoreApplication::exec() );
|
||||||
|
} // main
|
1
examples/redis/CMakeLists.txt
Normal file
1
examples/redis/CMakeLists.txt
Normal file
@ -0,0 +1 @@
|
|||||||
|
add_subdirectory(01_client)
|
@ -15,12 +15,14 @@
|
|||||||
#else
|
#else
|
||||||
#define MYXLIB_API
|
#define MYXLIB_API
|
||||||
#endif
|
#endif
|
||||||
#define MYXLIB_INLINE inline
|
#define MYXLIB_INLINE inline // NOLINT
|
||||||
#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
|
#endif // ifdef MYXLIB_BUILD_LIBRARIES
|
||||||
|
|
||||||
#ifdef MYXLIB_HEADER_ONLY
|
#ifdef MYXLIB_HEADER_ONLY
|
||||||
#include "config-inl.hpp"
|
#include "config-inl.hpp"
|
||||||
|
@ -14,10 +14,10 @@ set(TRGT_moc_hpp
|
|||||||
${CMAKE_CURRENT_SOURCE_DIR}/client.hpp
|
${CMAKE_CURRENT_SOURCE_DIR}/client.hpp
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/lexer.hpp
|
${CMAKE_CURRENT_SOURCE_DIR}/lexer.hpp
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/parser.hpp
|
${CMAKE_CURRENT_SOURCE_DIR}/parser.hpp
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/reply.hpp
|
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/request.hpp)
|
${CMAKE_CURRENT_SOURCE_DIR}/request.hpp)
|
||||||
|
|
||||||
set(TRGT_hpp
|
set(TRGT_hpp
|
||||||
|
${CMAKE_CURRENT_SOURCE_DIR}/reply.hpp
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/client-inl.hpp
|
${CMAKE_CURRENT_SOURCE_DIR}/client-inl.hpp
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/lexer-inl.hpp
|
${CMAKE_CURRENT_SOURCE_DIR}/lexer-inl.hpp
|
||||||
${CMAKE_CURRENT_SOURCE_DIR}/parser-inl.hpp
|
${CMAKE_CURRENT_SOURCE_DIR}/parser-inl.hpp
|
||||||
@ -26,13 +26,15 @@ set(TRGT_hpp
|
|||||||
set(TRGT_headers ${TRGT_moc_hpp} ${TRGT_hpp})
|
set(TRGT_headers ${TRGT_moc_hpp} ${TRGT_hpp})
|
||||||
# cmake-format: on
|
# cmake-format: on
|
||||||
|
|
||||||
|
qt5_wrap_cpp(TRGT_moc_cpp ${TRGT_moc_hpp})
|
||||||
|
|
||||||
add_library(${TRGT}-header-only INTERFACE)
|
add_library(${TRGT}-header-only INTERFACE)
|
||||||
target_include_directories(
|
target_include_directories(
|
||||||
${TRGT}-header-only SYSTEM INTERFACE "$<BUILD_INTERFACE:${CMAKE_CURRENT_LIST_DIR}/include>"
|
${TRGT}-header-only SYSTEM INTERFACE "$<BUILD_INTERFACE:${CMAKE_CURRENT_LIST_DIR}/include>"
|
||||||
"$<INSTALL_INTERFACE:${CMAKE_INSTALL_INCLUDEDIR}>")
|
"$<INSTALL_INTERFACE:${CMAKE_INSTALL_INCLUDEDIR}>")
|
||||||
|
|
||||||
if(MYXLIB_BUILD_LIBRARIES)
|
if(MYXLIB_BUILD_LIBRARIES)
|
||||||
add_common_library(${TRGT} OUTPUT_NAME myx-${TRGT} SOURCES ${TRGT_cpp} ${TRGT_headers})
|
add_common_library(${TRGT} OUTPUT_NAME myx-${TRGT} SOURCES ${TRGT_moc_cpp} ${TRGT_cpp} ${TRGT_headers})
|
||||||
common_target_properties(${TRGT})
|
common_target_properties(${TRGT})
|
||||||
|
|
||||||
# Создание цели для проверки утилитой clang-tidy
|
# Создание цели для проверки утилитой clang-tidy
|
||||||
|
@ -3,7 +3,6 @@
|
|||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#include <myx/base/config.hpp>
|
|
||||||
#include <myx/redis/lexer.hpp>
|
#include <myx/redis/lexer.hpp>
|
||||||
#include <myx/redis/parser.hpp>
|
#include <myx/redis/parser.hpp>
|
||||||
#include <myx/redis/request.hpp>
|
#include <myx/redis/request.hpp>
|
||||||
@ -16,6 +15,8 @@ namespace myx {
|
|||||||
|
|
||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
|
QT_FORWARD_DECLARE_CLASS( ClientPrivate )
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @brief Provides access to a Redis server
|
* @brief Provides access to a Redis server
|
||||||
*/
|
*/
|
||||||
@ -111,36 +112,36 @@ public:
|
|||||||
|
|
||||||
private:
|
private:
|
||||||
|
|
||||||
class ClientPrivate : public QObject
|
|
||||||
{
|
|
||||||
Q_OBJECT
|
|
||||||
|
|
||||||
friend class Client;
|
|
||||||
|
|
||||||
explicit ClientPrivate( Client* client = nullptr ) :
|
|
||||||
m_lexer ( &m_socket ),
|
|
||||||
m_parser( &m_lexer )
|
|
||||||
{
|
|
||||||
connect( &m_socket, &QTcpSocket::connected, client, &Client::connected );
|
|
||||||
connect( &m_socket, &QTcpSocket::disconnected, client, &Client::disconnected );
|
|
||||||
connect( &m_parser, &Parser::reply, this, &ClientPrivate::sendReply );
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
QTcpSocket m_socket;
|
|
||||||
QQueue< Request* > m_queue;
|
|
||||||
Lexer m_lexer;
|
|
||||||
Parser m_parser;
|
|
||||||
|
|
||||||
Q_SLOT void sendReply( const myx::redis::Reply& reply )
|
|
||||||
{
|
|
||||||
Q_EMIT m_queue.dequeue()->reply( reply );
|
|
||||||
}
|
|
||||||
}; // class ClientPrivate
|
|
||||||
|
|
||||||
const QScopedPointer< ClientPrivate > d;
|
const QScopedPointer< ClientPrivate > d;
|
||||||
}; // class Client
|
}; // class Client
|
||||||
|
|
||||||
|
class ClientPrivate : public QObject
|
||||||
|
{
|
||||||
|
Q_OBJECT
|
||||||
|
|
||||||
|
friend class Client;
|
||||||
|
|
||||||
|
explicit ClientPrivate( Client* client = nullptr ) :
|
||||||
|
m_lexer ( &m_socket ),
|
||||||
|
m_parser( &m_lexer )
|
||||||
|
{
|
||||||
|
connect( &m_socket, &QTcpSocket::connected, client, &Client::connected );
|
||||||
|
connect( &m_socket, &QTcpSocket::disconnected, client, &Client::disconnected );
|
||||||
|
connect( &m_parser, &Parser::reply, this, &ClientPrivate::sendReply );
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
QTcpSocket m_socket;
|
||||||
|
QQueue< Request* > m_queue;
|
||||||
|
Lexer m_lexer;
|
||||||
|
Parser m_parser;
|
||||||
|
|
||||||
|
Q_SLOT void sendReply( const myx::redis::Reply& reply )
|
||||||
|
{
|
||||||
|
Q_EMIT m_queue.dequeue()->reply( reply );
|
||||||
|
}
|
||||||
|
}; // class ClientPrivate
|
||||||
|
|
||||||
} // namespace redis
|
} // namespace redis
|
||||||
|
|
||||||
} // namespace myx
|
} // namespace myx
|
||||||
|
@ -14,6 +14,18 @@ namespace myx {
|
|||||||
|
|
||||||
namespace redis {
|
namespace redis {
|
||||||
|
|
||||||
|
class Loop : public QObject
|
||||||
|
{
|
||||||
|
Q_OBJECT
|
||||||
|
|
||||||
|
friend class Request;
|
||||||
|
explicit Loop( QObject* parent = nullptr ) { Q_UNUSED( parent ) }
|
||||||
|
|
||||||
|
QEventLoop m_loop;
|
||||||
|
Q_SLOT void quitEventLoop() { m_loop.exit( 1 ); }
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @brief Represents a Redis command and its response
|
* @brief Represents a Redis command and its response
|
||||||
*/
|
*/
|
||||||
@ -54,17 +66,6 @@ public:
|
|||||||
|
|
||||||
private:
|
private:
|
||||||
|
|
||||||
class Loop : public QObject
|
|
||||||
{
|
|
||||||
Q_OBJECT
|
|
||||||
|
|
||||||
friend class Request;
|
|
||||||
explicit Loop( QObject* parent = nullptr );
|
|
||||||
|
|
||||||
QEventLoop m_loop;
|
|
||||||
Q_SLOT void quitEventLoop() { m_loop.exit( 1 ); }
|
|
||||||
};
|
|
||||||
|
|
||||||
|
|
||||||
const QScopedPointer< Loop > d;
|
const QScopedPointer< Loop > d;
|
||||||
}; // class Request
|
}; // class Request
|
||||||
|
46
src/myx/redis/request_p-inl.hpp
Normal file
46
src/myx/redis/request_p-inl.hpp
Normal file
@ -0,0 +1,46 @@
|
|||||||
|
#ifndef MYX_REDIS_REQUEST_INL_HPP_
|
||||||
|
#define MYX_REDIS_REQUEST_INL_HPP_
|
||||||
|
|
||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <myx/base/config.hpp>
|
||||||
|
|
||||||
|
#ifndef MYXLIB_HEADER_ONLY
|
||||||
|
#include <myx/redis/request.hpp>
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#include <QTimer>
|
||||||
|
|
||||||
|
namespace myx {
|
||||||
|
|
||||||
|
namespace redis {
|
||||||
|
|
||||||
|
MYXLIB_INLINE Request::Request( QObject* parent ) :
|
||||||
|
QObject( parent ),
|
||||||
|
d ( new Loop( parent ) )
|
||||||
|
{
|
||||||
|
connect( this, &Request::reply, this, &Request::deleteLater );
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
MYXLIB_INLINE bool Request::waitForReply( int msecs )
|
||||||
|
{
|
||||||
|
QTimer timer;
|
||||||
|
timer.setInterval( msecs );
|
||||||
|
timer.setSingleShot( true );
|
||||||
|
|
||||||
|
connect( &timer, &QTimer::timeout, &d->m_loop, &QEventLoop::quit );
|
||||||
|
connect( this, &Request::reply, d.data(), &Loop::quitEventLoop );
|
||||||
|
|
||||||
|
/*
|
||||||
|
* If the timer fires, the return value will be 0.
|
||||||
|
* Otherwise, quitEventLoop() will terminate the loop with 1.
|
||||||
|
*/
|
||||||
|
return( ( d->m_loop.exec( QEventLoop::ExcludeUserInputEvents ) != 0 ) );
|
||||||
|
}
|
||||||
|
|
||||||
|
} // namespace redis
|
||||||
|
|
||||||
|
} // namespace myx
|
||||||
|
|
||||||
|
#endif // ifndef MYX_REDIS_REQUEST_INL_HPP_
|
Loading…
Reference in New Issue
Block a user