From 23a11dd103e7a9c03ea0931fb9fb14cfbebacc06 Mon Sep 17 00:00:00 2001 From: Your Name Date: Mon, 11 Apr 2022 17:52:15 +0800 Subject: [PATCH] init --- .vscode/settings.json | 61 +++++++++++ CMakeLists.txt | 88 ++++++++++++++++ README.md | 8 ++ cmake/FindFFmpeg.cmake | 120 ++++++++++++++++++++++ cmake/FindGFlags.cmake | 96 ++++++++++++++++++ cmake/FindGlog.cmake | 94 +++++++++++++++++ cmake/FindMYSQL.cmake | 129 ++++++++++++++++++++++++ docker/Dockerfile | 0 framework/CMakeLists.txt | 42 ++++++++ lib/libmodels.so | Bin 0 -> 27504 bytes modules/CMakeLists.txt | 85 ++++++++++++++++ modules/TcpServer/include/TcpServer.hpp | 35 +++++++ modules/TcpServer/src/TcpServer.cpp | 18 ++++ modules/UserApp/include/UserApp.hpp | 94 +++++++++++++++++ modules/UserApp/src/UserApp.cpp | 42 ++++++++ source/config/config.ini | 0 source/src/main.cpp | 54 ++++++++++ 17 files changed, 966 insertions(+) create mode 100644 .vscode/settings.json create mode 100755 CMakeLists.txt create mode 100644 README.md create mode 100644 cmake/FindFFmpeg.cmake create mode 100644 cmake/FindGFlags.cmake create mode 100644 cmake/FindGlog.cmake create mode 100644 cmake/FindMYSQL.cmake create mode 100644 docker/Dockerfile create mode 100644 framework/CMakeLists.txt create mode 100755 lib/libmodels.so create mode 100644 modules/CMakeLists.txt create mode 100644 modules/TcpServer/include/TcpServer.hpp create mode 100644 modules/TcpServer/src/TcpServer.cpp create mode 100644 modules/UserApp/include/UserApp.hpp create mode 100644 modules/UserApp/src/UserApp.cpp create mode 100644 source/config/config.ini create mode 100644 source/src/main.cpp diff --git a/.vscode/settings.json b/.vscode/settings.json new file mode 100644 index 0000000..81c7f08 --- /dev/null +++ b/.vscode/settings.json @@ -0,0 +1,61 @@ +{ + "files.associations": { + "*.cpp": "cpp", + "iostream": "cpp", + "functional": "cpp", + "cctype": "cpp", + "clocale": "cpp", + "cmath": "cpp", + "cstdarg": "cpp", + "cstddef": "cpp", + "cstdio": "cpp", + "cstdlib": "cpp", + "cstring": "cpp", + "ctime": "cpp", + "cwchar": "cpp", + "cwctype": "cpp", + "array": "cpp", + "atomic": "cpp", + "strstream": "cpp", + "*.tcc": "cpp", + "bitset": "cpp", + "chrono": "cpp", + "complex": "cpp", + "condition_variable": "cpp", + "cstdint": "cpp", + "deque": "cpp", + "forward_list": "cpp", + "list": "cpp", + "unordered_map": "cpp", + "unordered_set": "cpp", + "vector": "cpp", + "exception": "cpp", + "algorithm": "cpp", + "ratio": "cpp", + "system_error": "cpp", + "tuple": "cpp", + "type_traits": "cpp", + "fstream": "cpp", + "initializer_list": "cpp", + "iomanip": "cpp", + "iosfwd": "cpp", + "istream": "cpp", + "limits": "cpp", + "memory": "cpp", + "mutex": "cpp", + "new": "cpp", + "ostream": "cpp", + "numeric": "cpp", + "sstream": "cpp", + "stdexcept": "cpp", + "streambuf": "cpp", + "thread": "cpp", + "cfenv": "cpp", + "cinttypes": "cpp", + "regex": "cpp", + "utility": "cpp", + "typeindex": "cpp", + "typeinfo": "cpp", + "valarray": "cpp" + } +} \ No newline at end of file diff --git a/CMakeLists.txt b/CMakeLists.txt new file mode 100755 index 0000000..0615cd3 --- /dev/null +++ b/CMakeLists.txt @@ -0,0 +1,88 @@ +if(" ${CMAKE_SOURCE_DIR}" STREQUAL " ${CMAKE_BINARY_DIR}") + message(FATAL_ERROR "Please create a separate directory for build files.") +endif() + +cmake_minimum_required(VERSION 3.6) + +project(ISNS C CXX) +set(CMAKE_VERBOSE_MAKEFILE OFF) + +# ---[ Options +option(build_modules "build modules" ON) + +# set(EXECUTABLE_OUTPUT_PATH ${PROJECT_SOURCE_DIR}/source/bin/) +if(build_modules) + add_subdirectory(modules) +endif() + +##OpenCV +if(WITH_OPENCV) + if(CMAKE_TOOLCHAIN_FILE) + if(EXISTS ${PROJECT_SOURCE_DIR}/include/opencv) + set(OpenCV_LIBS opencv_core opencv_imgproc opencv_highgui opencv_features2d opencv_flann) + if(EXISTS ${PROJECT_SOURCE_DIR}/include/opencv2/imgcodecs) + list(APPEND OpenCV_LIBS opencv_imgcodecs) + endif() + if(EXISTS ${PROJECT_SOURCE_DIR}/include/opencv2/videoio) + list(APPEND OpenCV_LIBS opencv_videoio) + endif() + message(STATUS "HAVE_OPENCV enabled") + message(STATUS "opencv libraries: ${OpenCV_LIBS}") + set(HAVE_OPENCV true) + set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -DHAVE_OPENCV") + else() + set (HAVE_OPENCV false) + endif() + else() + set(OpenCV_FIND_QUIETLY true) + #find_package(OpenCV REQUIRED) //this will include opencv_ts which result in crash on centos + find_package(OpenCV OPTIONAL_COMPONENTS imgcodecs) + find_package(OpenCV OPTIONAL_COMPONENTS videoio) + set(optional_opencv_libs ${OpenCV_LIBS}) + find_package(OpenCV REQUIRED core imgproc highgui features2d) + if(OpenCV_FOUND) + if(imgcodecs_FOUND) + list(APPEND OpenCV_LIBS optional_opencv_libs) + endif() + message(STATUS "HAVE_OPENCV enabled") + message(STATUS "opencv libraries: ${OpenCV_LIBS}") + set(HAVE_OPENCV true) + set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -DHAVE_OPENCV") + else() + set (HAVE_OPENCV false) + endif() + endif() +else() + set (HAVE_OPENCV false) +endif() + +#查找mysql是否安装 +find_package(MYSQL QUIET) +if(MYSQL_FOUND AND ENABLE_MYSQL) + message(STATUS "找到mysqlclient库:\"${MYSQL_INCLUDE_DIR}\",ENABLE_MYSQL宏已打开") + include_directories(${MYSQL_INCLUDE_DIR}) + include_directories(${MYSQL_INCLUDE_DIR}/mysql) + add_definitions(-DENABLE_MYSQL) + list(APPEND 3RDPARTY_LIBS ${MYSQL_LIBRARIES}) +endif() + +include_directories(${PROJECT_SOURCE_DIR}/3rdparty/rapidjson/include/) +include_directories(/usr/local/include/hv) +include_directories(${PROJECT_SOURCE_DIR}/modules/UserApp/include/) + + +# 寻找当前目录下所有源文件 +aux_source_directory(./source/src DIR_SRCS) + +add_compile_options(-Wall -std=c++11 -O2 -g) + +link_directories(${PROJECT_SOURCE_DIR}/lib) +link_directories(/usr/local/lib) + +list(APPEND ALL_LINKER_LIBS mk_api ZLToolKit dl ${3RDPARTY_LIBS} ${OpenCV_LIBS} pthread hv models) + +# 指定生成的目标 +add_executable(main ${DIR_SRCS}) + +# 链接 +target_link_libraries(main ${ALL_LINKER_LIBS}) \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000..4e53b47 --- /dev/null +++ b/README.md @@ -0,0 +1,8 @@ +## Satellite +*** +> Satellite + + + + + diff --git a/cmake/FindFFmpeg.cmake b/cmake/FindFFmpeg.cmake new file mode 100644 index 0000000..aba0eec --- /dev/null +++ b/cmake/FindFFmpeg.cmake @@ -0,0 +1,120 @@ +# ============================================== +# Try to find FFmpeg libraries: +# - avcodec +# - avformat +# - avdevice +# - avutil +# - swscale +# - avfilter +# +# FFMPEG_FOUND - system has FFmpeg +# FFMPEG_INCLUDE_DIR - the FFmpeg inc directory +# FFMPEG_LIBRARIES - Link these to use FFmpeg +# ============================================== +# Notice: this original script is from internet. + +if (FFMPEG_LIBRARIES AND FFMPEG_INCLUDE_DIR) + # in cache already + set(FFMPEG_FOUND TRUE) +else (FFMPEG_LIBRARIES AND FFMPEG_INCLUDE_DIR) + + find_path( + FFMPEG_AVCODEC_INCLUDE_DIR + NAMES libavcodec/avcodec.h + PATHS ${_FFMPEG_AVCODEC_INCLUDE_DIRS} + /usr/include/ffmpeg + /usr/local/include + /usr/local/ffmpeg/include + ) + + find_library( + FFMPEG_LIBAVCODEC + NAMES avcodec + PATHS ${_FFMPEG_AVCODEC_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu/ + ) + + find_library( + FFMPEG_LIBAVFORMAT + NAMES avformat + PATHS ${_FFMPEG_AVFORMAT_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu + ) + + find_library( + FFMPEG_LIBSWRESAMPLE + NAMES swresample + PATHS ${_FFMPEG_SWRESAMPLE_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu/ + ) + + find_library( + FFMPEG_LIBAVUTIL + NAMES avutil + PATHS ${_FFMPEG_AVUTIL_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu/ + ) + + find_library( + FFMPEG_LIBSWSCALE + NAMES swscale + PATHS ${_FFMPEG_SWSCALE_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu/ + ) + + find_library( + FFMPEG_LIBAVFILTER + NAMES avfilter + PATHS ${_FFMPEG_AVFILTER_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu/ + ) + find_library( + FFMPEG_LIBAVDEVICE + NAMES avdevice + PATHS ${_FFMPEG_AVDEVICE_LIBRARY_DIRS} + /usr/lib64 + /usr/local/lib + /usr/local/ffmpeg/lib + /usr/lib/aarch64-linux-gnu/ + ) + if (WITH_FFMPEG_AVDEVICE AND NOT FFMPEG_LIBAVDEVICE) + message(FATAL_ERROR "Not find FFmpeg LIBAVDEVICE ") + endif () + if (FFMPEG_LIBAVCODEC AND FFMPEG_LIBAVFORMAT AND FFMPEG_LIBAVUTIL AND FFMPEG_LIBSWSCALE AND FFMPEG_LIBSWRESAMPLE AND (FFMPEG_LIBAVDEVICE OR NOT WITH_FFMPEG_AVDEVICE)) + set(FFMPEG_FOUND TRUE) + endif () + + if (FFMPEG_FOUND) + set(FFMPEG_INCLUDE_DIR ${FFMPEG_AVCODEC_INCLUDE_DIR}) + set(FFMPEG_LIBRARIES + ${FFMPEG_LIBAVCODEC} + ${FFMPEG_LIBAVFORMAT} + ${FFMPEG_LIBAVUTIL} + ${FFMPEG_LIBSWSCALE} + ${FFMPEG_LIBSWRESAMPLE}) + if (WITH_FFMPEG_AVDEVICE) + list(APPEND FFMPEG_LIBRARIES ${FFMPEG_LIBAVDEVICE}) + endif (WITH_FFMPEG_AVDEVICE) + else (FFMPEG_FOUND) + message(FATAL_ERROR "Could not find FFmpeg libraries!") + endif (FFMPEG_FOUND) + +endif (FFMPEG_LIBRARIES AND FFMPEG_INCLUDE_DIR) diff --git a/cmake/FindGFlags.cmake b/cmake/FindGFlags.cmake new file mode 100644 index 0000000..579d750 --- /dev/null +++ b/cmake/FindGFlags.cmake @@ -0,0 +1,96 @@ +#COPYRIGHT +# +#All contributions by the University of California: +#Copyright (c) 2014-2017 The Regents of the University of California (Regents) +#All rights reserved. +# +#All other contributions: +#Copyright (c) 2014-2017, the respective contributors +#All rights reserved. +# +#Caffe uses a shared copyright model: each contributor holds copyright over +#their contributions to Caffe. The project versioning records all such +#contribution and copyright details. If a contributor wants to further mark +#their specific copyright on a particular contribution, they should indicate +#their copyright solely in the commit message of the change when it is +#committed. +# +#LICENSE +# +#Redistribution and use in source and binary forms, with or without +#modification, are permitted provided that the following conditions are met: +# +#1. Redistributions of source code must retain the above copyright notice, this +# list of conditions and the following disclaimer. +#2. Redistributions in binary form must reproduce the above copyright notice, +# this list of conditions and the following disclaimer in the documentation +# and/or other materials provided with the distribution. +# +#THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND +#ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED +#WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE +#DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR +#ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES +#(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; +#LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND +#ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +#(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS +#SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. +# +#CONTRIBUTION AGREEMENT +# +#By contributing to the BVLC/caffe repository through pull-request, comment, +#or otherwise, the contributor releases their content to the +#license and copyright terms herein. +# + +# - Try to find GFLAGS +# +# The following variables are optionally searched for defaults +# GFLAGS_ROOT_DIR: Base directory where all GFLAGS components are found +# +# The following are set after configuration is done: +# GFLAGS_FOUND +# GFLAGS_INCLUDE_DIRS +# GFLAGS_LIBRARIES +# GFLAGS_LIBRARYRARY_DIRS + +include(FindPackageHandleStandardArgs) + +set(GFLAGS_ROOT_DIR "" CACHE PATH "Folder contains Gflags") + +# We are testing only a couple of files in the include directories +if(WIN32) + find_path(GFLAGS_INCLUDE_DIR gflags/gflags.h + PATHS ${GFLAGS_ROOT_DIR}/src/windows) +else() + find_path(GFLAGS_INCLUDE_DIR gflags/gflags.h + PATHS ${GFLAGS_ROOT_DIR}) +endif() + +if(MSVC) + find_library(GFLAGS_LIBRARY_RELEASE + NAMES libgflags + PATHS ${GFLAGS_ROOT_DIR} + PATH_SUFFIXES Release) + + find_library(GFLAGS_LIBRARY_DEBUG + NAMES libgflags-debug + PATHS ${GFLAGS_ROOT_DIR} + PATH_SUFFIXES Debug) + + set(GFLAGS_LIBRARY optimized ${GFLAGS_LIBRARY_RELEASE} debug ${GFLAGS_LIBRARY_DEBUG}) +else() + find_library(GFLAGS_LIBRARY gflags) +endif() + +find_package_handle_standard_args(GFlags DEFAULT_MSG GFLAGS_INCLUDE_DIR GFLAGS_LIBRARY) + + +if(GFLAGS_FOUND) + set(GFLAGS_INCLUDE_DIRS ${GFLAGS_INCLUDE_DIR}) + set(GFLAGS_LIBRARIES ${GFLAGS_LIBRARY}) + message(STATUS "Found gflags (include: ${GFLAGS_INCLUDE_DIR}, library: ${GFLAGS_LIBRARY})") + mark_as_advanced(GFLAGS_LIBRARY_DEBUG GFLAGS_LIBRARY_RELEASE + GFLAGS_LIBRARY GFLAGS_INCLUDE_DIR GFLAGS_ROOT_DIR) +endif() diff --git a/cmake/FindGlog.cmake b/cmake/FindGlog.cmake new file mode 100644 index 0000000..accbf93 --- /dev/null +++ b/cmake/FindGlog.cmake @@ -0,0 +1,94 @@ +#COPYRIGHT +# +#All contributions by the University of California: +#Copyright (c) 2014-2017 The Regents of the University of California (Regents) +#All rights reserved. +# +#All other contributions: +#Copyright (c) 2014-2017, the respective contributors +#All rights reserved. +# +#Caffe uses a shared copyright model: each contributor holds copyright over +#their contributions to Caffe. The project versioning records all such +#contribution and copyright details. If a contributor wants to further mark +#their specific copyright on a particular contribution, they should indicate +#their copyright solely in the commit message of the change when it is +#committed. +# +#LICENSE +# +#Redistribution and use in source and binary forms, with or without +#modification, are permitted provided that the following conditions are met: +# +#1. Redistributions of source code must retain the above copyright notice, this +# list of conditions and the following disclaimer. +#2. Redistributions in binary form must reproduce the above copyright notice, +# this list of conditions and the following disclaimer in the documentation +# and/or other materials provided with the distribution. +# +#THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND +#ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED +#WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE +#DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR +#ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES +#(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; +#LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND +#ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +#(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS +#SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. +# +#CONTRIBUTION AGREEMENT +# +#By contributing to the BVLC/caffe repository through pull-request, comment, +#or otherwise, the contributor releases their content to the +#license and copyright terms herein. +# + +# - Try to find Glog +# +# The following variables are optionally searched for defaults +# GLOG_ROOT_DIR: Base directory where all GLOG components are found +# +# The following are set after configuration is done: +# GLOG_FOUND +# GLOG_INCLUDE_DIRS +# GLOG_LIBRARIES +# GLOG_LIBRARYRARY_DIRS + +include(FindPackageHandleStandardArgs) + +set(GLOG_ROOT_DIR "" CACHE PATH "Folder contains Google glog") + +if(WIN32) + find_path(GLOG_INCLUDE_DIR glog/logging.h + PATHS ${GLOG_ROOT_DIR}/src/windows) +else() + find_path(GLOG_INCLUDE_DIR glog/logging.h + PATHS ${GLOG_ROOT_DIR}) +endif() + +if(MSVC) + find_library(GLOG_LIBRARY_RELEASE libglog_static + PATHS ${GLOG_ROOT_DIR} + PATH_SUFFIXES Release) + + find_library(GLOG_LIBRARY_DEBUG libglog_static + PATHS ${GLOG_ROOT_DIR} + PATH_SUFFIXES Debug) + + set(GLOG_LIBRARY optimized ${GLOG_LIBRARY_RELEASE} debug ${GLOG_LIBRARY_DEBUG}) +else() + find_library(GLOG_LIBRARY glog + PATHS ${GLOG_ROOT_DIR} + PATH_SUFFIXES lib lib64) +endif() + +find_package_handle_standard_args(Glog DEFAULT_MSG GLOG_INCLUDE_DIR GLOG_LIBRARY) + +if(GLOG_FOUND) + set(GLOG_INCLUDE_DIRS ${GLOG_INCLUDE_DIR}) + set(GLOG_LIBRARIES ${GLOG_LIBRARY}) + message(STATUS "Found glog (include: ${GLOG_INCLUDE_DIR}, library: ${GLOG_LIBRARY})") + mark_as_advanced(GLOG_ROOT_DIR GLOG_LIBRARY_RELEASE GLOG_LIBRARY_DEBUG + GLOG_LIBRARY GLOG_INCLUDE_DIR) +endif() diff --git a/cmake/FindMYSQL.cmake b/cmake/FindMYSQL.cmake new file mode 100644 index 0000000..b82e6e1 --- /dev/null +++ b/cmake/FindMYSQL.cmake @@ -0,0 +1,129 @@ +# - Try to find MySQL / MySQL Embedded library +# Find the MySQL includes and client library +# This module defines +# MYSQL_INCLUDE_DIR, where to find mysql.h +# MYSQL_LIBRARIES, the libraries needed to use MySQL. +# MYSQL_LIB_DIR, path to the MYSQL_LIBRARIES +# MYSQL_EMBEDDED_LIBRARIES, the libraries needed to use MySQL Embedded. +# MYSQL_EMBEDDED_LIB_DIR, path to the MYSQL_EMBEDDED_LIBRARIES +# MYSQL_FOUND, If false, do not try to use MySQL. +# MYSQL_EMBEDDED_FOUND, If false, do not try to use MySQL Embedded. + +# Copyright (c) 2006-2008, Jarosław Staniek +# +# Redistribution and use is allowed according to the terms of the BSD license. +# For details see the accompanying COPYING-CMAKE-SCRIPTS file. + +include(CheckCXXSourceCompiles) + +if(WIN32) + find_path(MYSQL_INCLUDE_DIR mysql.h + PATHS + $ENV{MYSQL_INCLUDE_DIR} + $ENV{MYSQL_DIR}/include + $ENV{ProgramFiles}/MySQL/*/include + $ENV{SystemDrive}/MySQL/*/include + $ENV{ProgramW6432}/MySQL/*/include + ) +else(WIN32) + find_path(MYSQL_INCLUDE_DIR mysql/mysql.h + PATHS + $ENV{MYSQL_INCLUDE_DIR} + $ENV{MYSQL_DIR}/include + /usr/local/mysql/include + PATH_SUFFIXES + mysql + ) +endif(WIN32) + +if(WIN32) + if (${CMAKE_BUILD_TYPE}) + string(TOLOWER ${CMAKE_BUILD_TYPE} CMAKE_BUILD_TYPE_TOLOWER) + endif() + + # path suffix for debug/release mode + # binary_dist: mysql binary distribution + # build_dist: custom build + if(CMAKE_BUILD_TYPE_TOLOWER MATCHES "debug") + set(binary_dist debug) + set(build_dist Debug) + else(CMAKE_BUILD_TYPE_TOLOWER MATCHES "debug") + ADD_DEFINITIONS(-DDBUG_OFF) + set(binary_dist opt) + set(build_dist Release) + endif(CMAKE_BUILD_TYPE_TOLOWER MATCHES "debug") + +# find_library(MYSQL_LIBRARIES NAMES mysqlclient + set(MYSQL_LIB_PATHS + $ENV{MYSQL_DIR}/lib/${binary_dist} + $ENV{MYSQL_DIR}/libmysql/${build_dist} + $ENV{MYSQL_DIR}/client/${build_dist} + $ENV{ProgramFiles}/MySQL/*/lib/${binary_dist} + $ENV{SystemDrive}/MySQL/*/lib/${binary_dist} + $ENV{MYSQL_DIR}/lib/opt + $ENV{MYSQL_DIR}/client/release + $ENV{ProgramFiles}/MySQL/*/lib/opt + $ENV{ProgramFiles}/MySQL/*/lib/ + $ENV{SystemDrive}/MySQL/*/lib/opt + $ENV{ProgramW6432}/MySQL/*/lib + ) + find_library(MYSQL_LIBRARIES NAMES libmysql + PATHS + ${MYSQL_LIB_PATHS} + ) +else(WIN32) +# find_library(MYSQL_LIBRARIES NAMES mysqlclient + set(MYSQL_LIB_PATHS + $ENV{MYSQL_DIR}/libmysql_r/.libs + $ENV{MYSQL_DIR}/lib + $ENV{MYSQL_DIR}/lib/mysql + /usr/local/mysql/lib + /opt/mysql/mysql/lib + $ENV{MYSQL_DIR}/libmysql_r/.libs + $ENV{MYSQL_DIR}/lib + $ENV{MYSQL_DIR}/lib/mysql + /usr/local/mysql/lib + /opt/mysql/mysql/lib + PATH_SUFFIXES + mysql + ) + find_library(MYSQL_LIBRARIES NAMES mysqlclient + PATHS + ${MYSQL_LIB_PATHS} + ) +endif(WIN32) + +find_library(MYSQL_EMBEDDED_LIBRARIES NAMES mysqld + PATHS + ${MYSQL_LIB_PATHS} +) + +if(MYSQL_LIBRARIES) + get_filename_component(MYSQL_LIB_DIR ${MYSQL_LIBRARIES} PATH) +endif(MYSQL_LIBRARIES) + +if(MYSQL_EMBEDDED_LIBRARIES) + get_filename_component(MYSQL_EMBEDDED_LIB_DIR ${MYSQL_EMBEDDED_LIBRARIES} PATH) +endif(MYSQL_EMBEDDED_LIBRARIES) + +set( CMAKE_REQUIRED_INCLUDES ${MYSQL_INCLUDE_DIR} ) +set( CMAKE_REQUIRED_LIBRARIES ${MYSQL_EMBEDDED_LIBRARIES} ) +check_cxx_source_compiles( "#include \nint main() { int i = MYSQL_OPT_USE_EMBEDDED_CONNECTION; }" HAVE_MYSQL_OPT_EMBEDDED_CONNECTION ) + +if(MYSQL_INCLUDE_DIR AND MYSQL_LIBRARIES) + set(MYSQL_FOUND TRUE) + message(STATUS "Found MySQL: ${MYSQL_INCLUDE_DIR}, ${MYSQL_LIBRARIES}") +else(MYSQL_INCLUDE_DIR AND MYSQL_LIBRARIES) + set(MYSQL_FOUND FALSE) + message(STATUS "MySQL not found.") +endif(MYSQL_INCLUDE_DIR AND MYSQL_LIBRARIES) + +if(MYSQL_INCLUDE_DIR AND MYSQL_EMBEDDED_LIBRARIES AND HAVE_MYSQL_OPT_EMBEDDED_CONNECTION) + set(MYSQL_EMBEDDED_FOUND TRUE) + message(STATUS "Found MySQL Embedded: ${MYSQL_INCLUDE_DIR}, ${MYSQL_EMBEDDED_LIBRARIES}") +else(MYSQL_INCLUDE_DIR AND MYSQL_EMBEDDED_LIBRARIES AND HAVE_MYSQL_OPT_EMBEDDED_CONNECTION) + set(MYSQL_EMBEDDED_FOUND FALSE) + message(STATUS "MySQL Embedded not found.") +endif(MYSQL_INCLUDE_DIR AND MYSQL_EMBEDDED_LIBRARIES AND HAVE_MYSQL_OPT_EMBEDDED_CONNECTION) + +mark_as_advanced(MYSQL_INCLUDE_DIR MYSQL_LIBRARIES MYSQL_EMBEDDED_LIBRARIES) diff --git a/docker/Dockerfile b/docker/Dockerfile new file mode 100644 index 0000000..e69de29 diff --git a/framework/CMakeLists.txt b/framework/CMakeLists.txt new file mode 100644 index 0000000..4dc6709 --- /dev/null +++ b/framework/CMakeLists.txt @@ -0,0 +1,42 @@ +cmake_minimum_required(VERSION 3.6) +set(LIBRARY_OUTPUT_PATH ${PROJECT_SOURCE_DIR}/lib/) +set(EXECUTABLE_OUTPUT_PATH ${PROJECT_BINARY_DIR}/bin/) +set(INS_ROOT_DIR ${CMAKE_CURRENT_SOURCE_DIR}/..) + +add_compile_options(-std=c++11) + +# compile flags +set(CMAKE_SHARED_LINKER_FLAGS "-Wl,--no-as-needed") +set(CMAKE_CXX_FLAGS_RELEASE "${CMAKE_CXX_FLAGS_RELEASE} -DNDEBUG -O2") +set(CMAKE_CXX_FLAGS_DEBUG "${CMAKE_CXX_FLAGS_DEBUG} -DDEBUG -g") +set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++11 -D_REENTRANT -fPIC -Wall -Werror") + +set(CNSTREAM_ROOT_DIR ${CMAKE_CURRENT_SOURCE_DIR}/..) +set(LIBRARY_OUTPUT_PATH ${CNSTREAM_ROOT_DIR}/lib) +set(EXECUTABLE_OUTPUT_PATH ${PROJECT_BINARY_DIR}/bin/) +set(CMAKE_MODULE_PATH ${CNSTREAM_ROOT_DIR}/cmake) + +set(VERSION_HEAD_FILE ${INS_ROOT_DIR}/framework/core/include/ins_version.hpp) + +execute_process(COMMAND awk /INS_MAJOR_VERSION/ ${VERSION_HEAD_FILE} OUTPUT_VARIABLE VERSION_STR) +string(REGEX MATCH "[0-9]+" MAJOR_VERSION ${VERSION_STR}) +execute_process(COMMAND awk /INS_MINOR_VERSION/ ${VERSION_HEAD_FILE} OUTPUT_VARIABLE VERSION_STR) +string(REGEX MATCH "[0-9]+" MINOR_VERSION ${VERSION_STR}) +execute_process(COMMAND awk /INS_PATCH_VERSION/ ${VERSION_HEAD_FILE} OUTPUT_VARIABLE VERSION_STR) +string(REGEX MATCH "[0-9]+" PATCH_VERSION ${VERSION_STR}) +set(ISNS_TARGET_VERSION "${MAJOR_VERSION}.${MINOR_VERSION}.${PATCH_VERSION}") + +include_directories(${3RDPARTY_INCLUDE_DIRS}) + +include_directories(${PROJECT_SOURCE_DIR}/3rdparty/) +include_directories(${PROJECT_SOURCE_DIR}/3rdparty/rapidjson/include/) +include_directories(${CMAKE_CURRENT_SOURCE_DIR}/dataType/include/) + +aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/core/src core_srcs) +aux_source_directory(${CMAKE_CURRENT_SOURCE_DIR}/dataType/src core_srcs) + +add_library(ins_core SHARED ${core_srcs} ) +target_link_libraries(ins_core protobuf ${SOURCE_LINKER_LIBS}) +target_link_libraries(ins_core dl pthread ${CNRT_LIBS} ${GFLAGS_LIBRARIES}) +set_target_properties(ins_core PROPERTIES LINK_FLAGS_RELEASE -s) +set_target_properties(ins_core PROPERTIES VERSION ${ISNS_TARGET_VERSION}) diff --git a/lib/libmodels.so b/lib/libmodels.so new file mode 100755 index 0000000000000000000000000000000000000000..8b83c02ac0703d92fa78f136226f2c15bb226d15 GIT binary patch literal 27504 zcmeHQdwkT@mA`ob3MLT&5m3hnNI=I-cnAnGLozVI04WI=A9R>ZCdp{X#K|NC7c2r& zLYgkCZfkvX>8@q1R*SZ}Xj_d!LECN{w-sr%noqUt1l$%M#Z)QT@43HoXYTywH;{yG zKmM^-e{+84+;h)8_uO+I`P~O!a+fYjPfHUjWQgkoVa|Mm;^c@uetrRPirHc)elHah zByUzcD(P*)T!W;b5H?AmJci)uyjG%sHu<7pD+}Ee6K=$(gNxEd=Sg-zgRWo~F(4>7 z%s@pZAU&^eQO$57^C?KY6w3Y(siyZe(knZU$L7}^+K#xRc|fy?ns#50KygvofO$TuO#9jD>Big7!` zs~I`~xr)R!c%OrZTx&ia3JVM%f1UVs;X%nnF&;Ob#ds)q@LZ3lln{iac$VY&0-hCk zD)6kta|0dTg)K{@$stpLj7N??jhp>&%CTw>)ld z{?vWn^%uWsFFADkqHkqf{OGY?{VDsY7j8_y#r@WgNB`oJi@&jA{ks^zaen)8oO-uJ?UTX(%Xdwa>m z-_41<^1bEHeDi0|AN7ta{wY%V|BJgXc&Oz2ANgd)!-YeJq+IboILkO9x@rpndAAK=#`HC(-t&2=A9^bv4;EB=>K&|f}Ri1Srq z4L$?9m7Fc<*7Q{==(*jEyMd&>9#0XKq4W0Te3J*$qju4+tHSin*i1EV> z{v+HWT*34mfFvhOod*KgWQZc)%S5*5E;Mk}j|^w|PL}^1^KXYeNzM-LfMzoNK(;}D zk2)ZPJOhZQU?AduoAXurTn_sXJ;LR3G5-Q6HWKt=R)qQ`3a{dk`LdjHNflxY;7D??5oPcP(#K|!)4=Uz$25ac`FRxe zLiT@_^-=P>xE{^r{TC#+@`wL{{zPBG^`+X~`17gXzDUe=*^G?&cPi&=?tgxi!ar|J zVTUKdPwn~~E*IEjn8x+^7MDx4qdeBr>{oWF=Q!bX*$e^v`$CHPx{CEN_lKvrJ(~Tk z2K^G%OQXq8ek?q zY=3hYsejf1B4|cbm7y7p&KfHKPPxDcxaCIXP;Dujw}F zF{n&y`GvZCRI8&9@{<)QT{Z_5)zBi0yt!j)Yz_y!Ex~Z4*+-*d#j0f}KaE(vs$h$w5bsSvub<{t-k8=j zo2e*2JExQB2d=Z>>;q_ChJ|MbLrt;?%fX)84f^3ky5Y>SKgR^6mFB8ugE(mBm%ok0hJi3i zj(PrYhV+=p#Pf0+a~aZmkm@AOH3p~-rU{nnB)8Hy+nGwJ2D5mI)ApQkwlfG;qhyMq zuD^1~(XB_30Z5=K8@!GFCiXb(#G}7O>E~!NFma}t>)`D)*b$|_>Z&otx_|Gl6j2|n z3N;2A{4L(PU~OG(bI{%tvd^&3)FNu|XCOwOrow71E*v4mL2T9a^jb)-jhIUZe3Gw# z@S932LZSNWgTzdDT?@Z(o-M)ZKqwfZ^oe-}*Vg(&)d7E#WmIE0R_n+20m5XVr2JXJ8>se0d>DhPFtEz+BOoBhUg&>@N{D_sjq zybinZK`5!}R&~>XXW_v|GpsNR3A04n=i)!8gFw1u$Zt?W*npQ!UXL$r zLq!>A6w;vc`5aH5L`Mbb%jpnN$+YHiL3~lm5LGe$3~>}6iSfS-k^Fn`WiU%LF#qkn zUxzU=#T|_Q>U+1rSm~mT)2sDzB$6SQ*DYS*@A-LF9M{9D*QqVmbeU-+q))A<@aDZ6-s_(02dY2|g=U=1I)i-gO zr$)b2lkKDk5Nk%O)}M6K?7fAL}&e)H~|!%cjw}sZ0JT z8eM&Jr-%ZLuGWf(K3k(NBmxJgMyK9c1&>C@C;nI{)98A8uhi&{7`G5>G&+q2D%5H8 zOB4~XQKQp-4;5N9I@w5tO&Z;;h=AKQy6WR7dZ$KLYaT?uU!$WVkA+i-5OnQzfp~zt;spA z(U)lSUX6|=nRsy7}oO?d9^jATWN;JuzL`-kn5?4oaG`b9R;Hz^apIhQ)|MtB`X z_H_3lO!^c_>(U7ClK6*&QxoXvl=xA?sq5+4Bk|u8PEDa_m&AWdIJtDsPKo~);nZFA zY?Am-2`9CC8YTWR;pB=vYb5?W;pA#PWfFgyaB{I8r^Fv4oLsA?K;r*OICX73Higkerm~iR}dpae4E8$cX zJ$ocxML2bRJ-Z}+6X7(J_Ux4S3c{%i?AavoC4^Jg*V8ERg@luf^sJHiT*5CRyiDSS zgpVWKDeN);bDt|iRHp06l z{^^ClFC)B5;+x0VM9t2=NsmeB>6rfk7(5+W1XgArh|GG5;xED7S6n$+qU+EgMg!H5cBsvA3@ecFjkHrJ*9C z_mZ%V(eIH_I%fWnKzr8iQ2@xU1v&40RmyyUlD$a%NAwZ0yChP+J2f5DJK1q8BBQWl zH!J~oF#4)d^e7D3%|?9ov%bD#xkf3+-mK)KB$OXmdr915NUPr8#yj*h zY@zttnvcu)_LavuyBp%gA-hOv30%1{K}Q+7S~n6M@U*=VEmZk*ctD0M74=JL=IG0x zTI9WDW3Px@Xk-s3>_ke~btM#kqpwS8nrx+mREOe4>NTQsDPL(BSPPoG6FrQaAQHwL zdu$GwpjHxAcYE%BGlJ5*6CESX_fGU}L`1(~2#CHWp>&@k^txp~*;KmCmiIlLwjWbF z^0YluDZxKeZ|!O8r~@c%yPNv*(zcFPfUTVoTTZ@vQ%?TUojLg{cje@--jkCb=*-Dq z+m(~w+?|uZ@i;q6%)0GamyaaJDl;tGmMd+B#)p<{RO580YOXnsI{X(|URm2CBpWN8 zSaUE0l^1S%kXn2^FT?y)`(?Sx<_R9Fe1P-omHB1eo-E~{a~OF(2|VbeEt?`HFD4_a zBsm>b(q=Tcq*BjERw+uo5d6wGVH1vZP%FeCGsHCVV=Tv>pS7D^+ zrIe;)bfYxb%zq%zo>iC&0DGm!6}0Yi*y3%?A1gD343&D@SAN_UuW3~?2`yaq-QIW> zF;7k4vg!vO_=M{vML+QTiFiK{vtq3O(_8i$l9bT0ziP;ix9koG^R#O%d!9`5PBarR z`l2Bq`iX?HWse{e7%khn7ldW^5_@~rQ`u*3CCYZ~Sz9c)A?v$;w(#m&Xr02VZ;^Q$ zP2MTlPVd#FWB_>eD8PPr^~1zw>DAP1Y3>}KDuZGj^uGtq9G2hX)t-^lFDyt=NI&2e zI$Z~(AIO@ROsbd1QvZH`fyVd1@fp|B*^tSQyz8UBzDm4z!{}3x3AKze!0!My0{#GS zEc%YW0^Sce627?!{Feak0-Ori4R|NuF!1jN+zI$|z&(I@=pMQN%K(o9z6LlJf0;~0 zPd6KI4PYhUHo#WE{ebrab^-1M9EDNtFyJb{Uce22v!Tb6fR%tE;* zf7#p)=)_+%+W_|xKVUE5uK~v*ekx`pvjM*gxCZbj;3mK;F)7;xxB{>na4R4k?%54! zqrZ?4Mj1e)-LXQXwdSUcA2D>;PS{`~=rqZ9e%RMnfU=70+(p@Am*fmzH*AwwFz(u^ z(*_4UHC7g$QOGbK0JfEK)pNse+J^h{W^ba9^2I5_M{Dye^ zj}X5K@u~EC3-R}%PbksTrx!~BWapEJr}3*$kB1G()D%Afrd@{kJUxDOJpXx!FGIZi zPNM2ySv>w0#IHvF^v8M3{zf%RKih!#14wV>uay5oh^KM2SWgfA?qL0Xg!m^BpR)Xj zr#{ch&&ZD`|D%YPesnXOL6yPeM-$OhiqQwAs^?DDJ`0X(KMna-~&e)rw{iU{aYr1>K1K|KHEE1=M<XaZ(PNG1nKPa}6z2yu*agGvSL(_zfn!)`T~j@HP|vhzb9(3IDYTr?p}V zO5eYja9W$z<7q9Lg8FtpopCmUa57FGj47ydne@S!f;wMzk%7j}Y10Q+3iQc^0)3FB zpw^LTe4s#cEDC=<)fXaooE1m!BSSZ5JcRK|^o11Y12={HSU)*N16TQBXfT4)CLxAO z845T;%^Qa@{X&L&E;n8jy^|Lom7d2rJ$-Pepz_0%RO(;A{P?aTaizy`#v{B)g{ilU zSLHOMeg1x<^K6z%jgf;s{%&D7i{T=Ms~FZWY+<;K;nx`MX80__0}Kx_Ji_n6m3Nm|=Gm<{J^V!UD&vf>{M~5(HQv8EDn&UIINj z1N%KxyGf*H2-RK^>6t>ct3-O1Q2v=nA0m`rC(?%s)jksG!-Q%_iS*=i-4vfet(ogL zk$<=-VEZQ0N5t-*NTes9ccu6Y^lnZ$`O>+Go)f#TL66D6?uT77bc*qwftB|C7PXXt z6MSl)jh-q)ToCK;66vEv_q8^iB;PZ%bGCY922S%@wZjZ?p-}r968X_9ale;Hzet$< zl;ShcJI{96=rti^2-S>b?+_iX;<#lc|1b zPY2P>^OIuG(=wmt9U+F*6L|6KcV!B!X?N>|jLh0{k{nb2F=}&rD>AwjP zX=sm~rgryLNl*4S%FRm71C)V9dw)X8Np2Uox7$T3RdTwL!gtM=6t`# z^gG!<)%@#mmcNVrS#_iDGQauUuNw|S^3CUdcQD<2-upj6A1P}j@#h%xo9{0u!2~NW zkyT;=(5>WrU-BoPCqKb-vp#b$F||6cemm$?F7rJC&oaN-=cne6e+1o1pV>nV`D(wQ z;%^0={kpk_|50W8<=iBpZ|5xd1{?ty;niEx>w?tEXRB=K-M`% zzGi=RGTm&SyP0l2fBsX@t?nrpfvJO)-6n%h_A&eCwUR&i9*vbL@C?(<_i_9bbSwKDk@V#G*!wKU zT#tDe;OU+M^SvrFK_`98_fTwPy4m0MgKkT(jDZ|xesg(`f=>0mo&OF|w!IjCfKtBZ zdZ`AT`nNUg|MNJnM?kmo=ie}YH}mswB}U*6Vv=vR=VeTPdzv9wOE{0MC!pj1oLMmh;vZNFyboEg?k@`enrFC6x*$Dxo&c)h3z`_=}$)y-?yu169LlUHgauzGJQ zkCZy*GzJ6yz`9^l0Eg@waB9BUPp26XHQVbAhK!3iB!B56c=7p-tDb$i{*is?2HSp(`F_wIS!9%k?q zuOQ1dg}imhA2*5=-(U|1YV6kcW)$DJ%(b+n2q`L-7AfJZ;_^j{%5fmE!nLr}O}9x{ zpK{dk&Eb@TxRAztZ-vvT9TPh{Pe0=sMVYs{#>eSY2ioWu zo6LEj#eoszML8@ge)8??%At;v#%w+4%YV-1;*J3xUrxRkMjq`QsK*ViBB=3MR6>fw z#mcT{*o%~^68pOq=x=?XcaV2F^jBS62Ouw&N$URM0!+6DnQm>cx}+enbsJZ3$qWXt zLo0r7!hrXMX=C32-TD9K(w?(F?yg-Ek<@`Djz@g0SiJU3cRA1vRS9i|=NSVul+`T? zxG5`1a$FCsQWCFP=wG``yl0DMMg#3*RR0=RNnM3ux%IDqY9$Yq3DsdZvFSdrcnxAo z&XZ#*&_EgoSF=(weytb@O0;jhyr=K^k}W*=X&uTfdll;|^WqwTk1iOIJ@x>KKRBPY zx@zOBZdtf0E?UGR;KDVX3=z{-x$3T9Y8tB8LB^VmOFSiN|G~pH!_;6 z?ELtKGm|CB+mprjufT@U^g9twI|e3Q^fK6dttJSGR|8S6k<^o-qyz2ov^&C*m5n#T z)B8no52wtljV!2#fzG0Fuam6U*kyJ7s@nc)ZHzV+H&>c+NxX$I#l<$Nz^6CV>2DcL zxKk6A%eQOLolllN+~0!2iiy{rN~7u*Z6%hNZbG%b?KFO)r#4h4`%V9hp-(FlotuOw zI=8SltzR4QRRKoA2CP$W4WUTDj%zLLRn5Wr>Z^j)LSl8kraED-Uf+O}28@J_7~F8x zgik*Sh!=6;K)sI=@LOYjMA+rnYsag-HUt#6aN$?ZR_)=CyfVcesN)Y{b=44}Fi6Ke zD}h#jpfTcw#`x$Xg&E(*3>oVERzDJwFj4_>rMkYgK|h3qB9yxkE$q0RMcDDlZY@5; zC4UYaD23MLv4n)RXCtWnCJIhux&l~sO9*yg*oqob>D9gz1?9t> zN`J+tAnjGAy~XdlA-ixvZ%(3DjU(%{u%|<{xg-oO0UY_!08uKVg$7h zM?tm!jnY#ZbNW`$uw+fgEM!po{S+L>bOlIPJv0H))5rGp@Ir|^i=idJXMPzJyc3w7 zUhV%;Q1NlHnEnd?vMIgVccS2LRDn5xSzd=Jz1rWXAeJE$g1P+na(Y$&YTuE9mr&uf zVAI~|^+7zuqSBlHT^aT7$Ph0DbN=4}O;4}(F)26^>)3iQnL~WvlwR$3Qm|4_jCXVX zKLHI(Sh4o4_C=|GuSWT)5@XK)HAG;^DVARC7d?Efk;2Sx#(xJkD!*zUYClqUKhyu- zlwPeHMLE3`Zm1%E&H4WcRBAgaf3304J_V&D10aqlPpz!wf;Dp z)2nf1~ytTa-<2Bd2; + + ~TcpServer(); + + /** + * @description: 创建新实例 + * @param {int} port + * @return {*} + */ + static std::shared_ptr CreateNew(int port); +private: + int port_; +}; + + +#endif diff --git a/modules/TcpServer/src/TcpServer.cpp b/modules/TcpServer/src/TcpServer.cpp new file mode 100644 index 0000000..1e6f721 --- /dev/null +++ b/modules/TcpServer/src/TcpServer.cpp @@ -0,0 +1,18 @@ +/* + * @Description: + * @Version: 1.0 + * @Autor: lishengyin + * @Date: 2022-04-11 17:31:02 + * @LastEditors: lishengyin + * @LastEditTime: 2022-04-11 17:43:05 + */ +#include "TcpServer.hpp" + +/** + * @description: 创建新的实例 + * @param {int} port + * @return {*} + */ +std::shared_ptr TcpServer::CreateNew(int port){ + return std::shared_ptr(new TcpServer(port)); +} \ No newline at end of file diff --git a/modules/UserApp/include/UserApp.hpp b/modules/UserApp/include/UserApp.hpp new file mode 100644 index 0000000..0421bf3 --- /dev/null +++ b/modules/UserApp/include/UserApp.hpp @@ -0,0 +1,94 @@ +/* + * @Description: + * @Version: 1.0 + * @Autor: lishengyin + * @Date: 2022-04-11 17:12:05 + * @LastEditors: lishengyin + * @LastEditTime: 2022-04-11 17:31:20 + */ +#ifndef __USERAPP_HPP_ +#define __USERAPP_HPP_ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +using namespace std; + + +#define OK 0 +#define ERR -1 + +// NonCopyAble +class NonCopyable { + protected: + NonCopyable() {}; + ~NonCopyable() {}; + + public: + NonCopyable(const NonCopyable&) = delete; + NonCopyable(NonCopyable&&) = delete; + NonCopyable& operator=(const NonCopyable&) = delete; + NonCopyable& operator=(NonCopyable&&) = delete; + + static std::string getDataTime(){ + char ctime[80]; + time_t rawtime; + struct tm *info; + time(&rawtime); + info = localtime(&rawtime); + strftime(ctime, 80, "%Y-%m-%d %H:%M:%S", info); + std::string DataTime = ctime; + return DataTime; + } +}; + +class UserApp:private NonCopyable +{ +private: + UserApp(std::string appName):appName_(appName){} +public: + using Ptr = std::shared_ptr; + + ~UserApp(){} + + /** + * @description: 创建新的实例 + * @param {string} appName + * @return {*} + */ + static std::shared_ptr CreateNew(std::string appName); + + /** + * @description: 初始化 + * @param {*} + * @return {*} + */ + int8_t Init(); + + /** + * @description: 启动任务 + * @param {*} + * @return {*} + */ + int8_t StartTask(); + +private: + std::string appName_; +}; + + + +#endif \ No newline at end of file diff --git a/modules/UserApp/src/UserApp.cpp b/modules/UserApp/src/UserApp.cpp new file mode 100644 index 0000000..585a408 --- /dev/null +++ b/modules/UserApp/src/UserApp.cpp @@ -0,0 +1,42 @@ +/* + * @Description: + * @Version: 1.0 + * @Autor: lishengyin + * @Date: 2022-04-11 17:12:10 + * @LastEditors: lishengyin + * @LastEditTime: 2022-04-11 17:41:49 + */ +#include "UserApp.hpp" + +/** + * @description: 创建新的实例 + * @param {string} appName + * @return {*} + */ +std::shared_ptr UserApp::CreateNew(std::string appName){ + return std::shared_ptr(new UserApp(appName)); +} + +/** + * @description: 初始化 + * @param {*} + * @return {*} + */ +int8_t UserApp::Init(){ + + return OK; +} + +/** + * @description: 启动任务 + * @param {*} + * @return {*} + */ +int8_t StartTask(){ + + + return OK; +} + + + diff --git a/source/config/config.ini b/source/config/config.ini new file mode 100644 index 0000000..e69de29 diff --git a/source/src/main.cpp b/source/src/main.cpp new file mode 100644 index 0000000..5d59adf --- /dev/null +++ b/source/src/main.cpp @@ -0,0 +1,54 @@ +#include +#include +#include "Util/logger.h" +#include "Util/NoticeCenter.h" +#include "UserApp.hpp" +#include "Network/TcpServer.h" + +using namespace std; +using namespace toolkit; + +class EchoSession: public TcpSession { +public: + EchoSession(const Socket::Ptr &sock) : + TcpSession(sock) { + DebugL; + } + ~EchoSession() { + DebugL; + } + virtual void onRecv(const Buffer::Ptr &buf) override{ + //处理客户端发送过来的数据 + TraceL << buf->data() << " from port:" << get_local_port(); + send(buf); + } + virtual void onError(const SockException &err) override{ + //客户端断开连接或其他原因导致该对象脱离TCPServer管理 + WarnL << err.what(); + } + virtual void onManager() override{ + //定时管理该对象，譬如会话超时检查 + DebugL; + } + +private: + Ticker _ticker; +}; + +int main(int argc, char *argv[]) +{ + //设置退出信号处理函数 + static semaphore sem; + signal(SIGINT, [](int) { sem.post(); });// 设置退出信号 + + // 设置日志 + Logger::Instance().add(std::make_shared()); + Logger::Instance().add(std::make_shared()); + Logger::Instance().setWriter(std::make_shared()); + + TcpServer::Ptr server(new TcpServer()); + server->start(7400);//监听9000端口 + + sem.wait(); + return 0; +}