task和mq改造

logs/themis-task.log

@@ -1,98 +0,0 @@
-2020-07-05 16:51:48.789| main | INFO |  -  | Starting ThemisTaskApplication on kingdeMacBook-Air.local with PID 6097 (/Users/king/git/themis-server/themis-task/target/classes started by king in /Users/king/git/themis-server) | [org.springframework.boot.StartupInfoLogger:55]
-2020-07-05 16:51:48.800| main | INFO |  -  | No active profile set, falling back to default profiles: default | [org.springframework.boot.SpringApplication:651]
-2020-07-05 16:51:50.813| main | INFO |  -  | Multiple Spring Data modules found, entering strict repository configuration mode! | [org.springframework.data.repository.config.RepositoryConfigurationDelegate:249]
-2020-07-05 16:51:50.818| main | INFO |  -  | Bootstrapping Spring Data Redis repositories in DEFAULT mode. | [org.springframework.data.repository.config.RepositoryConfigurationDelegate:127]
-2020-07-05 16:51:50.871| main | INFO |  -  | Finished Spring Data repository scanning in 23ms. Found 0 Redis repository interfaces. | [org.springframework.data.repository.config.RepositoryConfigurationDelegate:187]
-2020-07-05 16:51:51.118| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBAppMapper' and 'com.qmth.themis.business.dao.TBAppMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.118| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBClientVersionMapper' and 'com.qmth.themis.business.dao.TBClientVersionMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.118| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBOrgMapper' and 'com.qmth.themis.business.dao.TBOrgMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.119| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBPrivilegeMapper' and 'com.qmth.themis.business.dao.TBPrivilegeMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.119| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBRoleMapper' and 'com.qmth.themis.business.dao.TBRoleMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.119| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBRolePrivilegeMapper' and 'com.qmth.themis.business.dao.TBRolePrivilegeMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.120| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBSessionMapper' and 'com.qmth.themis.business.dao.TBSessionMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.120| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBUserMapper' and 'com.qmth.themis.business.dao.TBUserMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.120| main | WARN |  -  | Skipping MapperFactoryBean with name 'TBUserRoleMapper' and 'com.qmth.themis.business.dao.TBUserRoleMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.120| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamActivityMapper' and 'com.qmth.themis.business.dao.TEExamActivityMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.121| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamBreachLogMapper' and 'com.qmth.themis.business.dao.TEExamBreachLogMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.121| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamCourseMapper' and 'com.qmth.themis.business.dao.TEExamCourseMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.122| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamMapper' and 'com.qmth.themis.business.dao.TEExamMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.122| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamPaperMapper' and 'com.qmth.themis.business.dao.TEExamPaperMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.123| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamReexamMapper' and 'com.qmth.themis.business.dao.TEExamReexamMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.123| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamStudentLogMapper' and 'com.qmth.themis.business.dao.TEExamStudentLogMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.123| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamStudentMapper' and 'com.qmth.themis.business.dao.TEExamStudentMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.124| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEExamUserPrivilegeMapper' and 'com.qmth.themis.business.dao.TEExamUserPrivilegeMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.124| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEStudentMapper' and 'com.qmth.themis.business.dao.TEStudentMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.124| main | WARN |  -  | Skipping MapperFactoryBean with name 'TEUserLogMapper' and 'com.qmth.themis.business.dao.TEUserLogMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.125| main | WARN |  -  | Skipping MapperFactoryBean with name 'TIeExamInvigilateNoticeMapper' and 'com.qmth.themis.business.dao.TIeExamInvigilateNoticeMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.125| main | WARN |  -  | Skipping MapperFactoryBean with name 'TIeInvigilateExceptionInfoMapper' and 'com.qmth.themis.business.dao.TIeInvigilateExceptionInfoMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.125| main | WARN |  -  | Skipping MapperFactoryBean with name 'TIeInvigilateWarnInfoMapper' and 'com.qmth.themis.business.dao.TIeInvigilateWarnInfoMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.125| main | WARN |  -  | Skipping MapperFactoryBean with name 'TOeExamAnswerMapper' and 'com.qmth.themis.business.dao.TOeExamAnswerMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.126| main | WARN |  -  | Skipping MapperFactoryBean with name 'TOeExamBreakHistoryMapper' and 'com.qmth.themis.business.dao.TOeExamBreakHistoryMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.126| main | WARN |  -  | Skipping MapperFactoryBean with name 'TOeExamRecordMapper' and 'com.qmth.themis.business.dao.TOeExamRecordMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.127| main | WARN |  -  | Skipping MapperFactoryBean with name 'TOeExamSimulateHistoryMapper' and 'com.qmth.themis.business.dao.TOeExamSimulateHistoryMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.127| main | WARN |  -  | Skipping MapperFactoryBean with name 'TOeFaceVerifyHistoryMapper' and 'com.qmth.themis.business.dao.TOeFaceVerifyHistoryMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.127| main | WARN |  -  | Skipping MapperFactoryBean with name 'TOeLivenessVerifyHistoryMapper' and 'com.qmth.themis.business.dao.TOeLivenessVerifyHistoryMapper' mapperInterface. Bean already defined with the same name! | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:51.128| main | WARN |  -  | No MyBatis mapper was found in '[com.qmth.themis.business.dao]' package. Please check your configuration. | [org.mybatis.logging.Logger:44]
-2020-07-05 16:51:52.307| main | INFO |  -  | Tomcat initialized with port(s): 6003 (http) | [org.springframework.boot.web.embedded.tomcat.TomcatWebServer:108]
-2020-07-05 16:51:52.322| main | INFO |  -  | Initializing ProtocolHandler ["http-nio-6003"] | [org.apache.juli.logging.DirectJDKLog:173]
-2020-07-05 16:51:52.324| main | INFO |  -  | Starting service [Tomcat] | [org.apache.juli.logging.DirectJDKLog:173]
-2020-07-05 16:51:52.325| main | INFO |  -  | Starting Servlet engine: [Apache Tomcat/9.0.35] | [org.apache.juli.logging.DirectJDKLog:173]
-2020-07-05 16:51:52.495| main | INFO |  -  | Initializing Spring embedded WebApplicationContext | [org.apache.juli.logging.DirectJDKLog:173]
-2020-07-05 16:51:52.496| main | INFO |  -  | Root WebApplicationContext: initialization completed in 3386 ms | [org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext:284]
-2020-07-05 16:51:53.085| main | INFO |  -  | Using default implementation for ThreadExecutor | [org.quartz.impl.StdSchedulerFactory:1220]
-2020-07-05 16:51:53.121| main | INFO |  -  | Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl | [org.quartz.core.SchedulerSignalerImpl:61]
-2020-07-05 16:51:53.123| main | INFO |  -  | Quartz Scheduler v.2.3.2 created. | [org.quartz.core.QuartzScheduler:229]
-2020-07-05 16:51:53.993| main | INFO |  -  | {dataSource-1} inited | [com.alibaba.druid.pool.DruidDataSource:1003]
-2020-07-05 16:51:53.999| main | INFO |  -  | Using db table-based data access locking (synchronization). | [org.quartz.impl.jdbcjobstore.JobStoreSupport:672]
-2020-07-05 16:51:54.004| main | INFO |  -  | JobStoreCMT initialized. | [org.quartz.impl.jdbcjobstore.JobStoreCMT:145]
-2020-07-05 16:51:54.005| main | INFO |  -  | Scheduler meta-data: Quartz Scheduler (v2.3.2) 'ClusterQuartz' with instanceId 'kingdeMacBook-Air.local1593939113089'
-  Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
-  NOT STARTED.
-  Currently in standby mode.
-  Number of jobs executed: 0
-  Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
-  Using job-store 'org.springframework.scheduling.quartz.LocalDataSourceJobStore' - which supports persistence. and is clustered.
- | [org.quartz.core.QuartzScheduler:294]
-2020-07-05 16:51:54.006| main | INFO |  -  | Quartz scheduler 'ClusterQuartz' initialized from an externally provided properties instance. | [org.quartz.impl.StdSchedulerFactory:1374]
-2020-07-05 16:51:54.006| main | INFO |  -  | Quartz scheduler version: 2.3.2 | [org.quartz.impl.StdSchedulerFactory:1378]
-2020-07-05 16:51:54.006| main | INFO |  -  | JobFactory set to: org.springframework.scheduling.quartz.SpringBeanJobFactory@1f7e52d1 | [org.quartz.core.QuartzScheduler:2293]
-2020-07-05 16:51:57.228| main | INFO |  -  | Initializing ExecutorService | [org.springframework.scheduling.concurrent.ExecutorConfigurationSupport:181]
-2020-07-05 16:51:57.230| main | INFO |  -  | Initializing ExecutorService | [org.springframework.scheduling.concurrent.ExecutorConfigurationSupport:181]
-2020-07-05 16:51:57.230| main | INFO |  -  | Initializing ExecutorService 'arbitrateThreadPool' | [org.springframework.scheduling.concurrent.ExecutorConfigurationSupport:181]
-2020-07-05 16:51:57.234| main | INFO |  -  | Initializing ExecutorService 'myThreadPool' | [org.springframework.scheduling.concurrent.ExecutorConfigurationSupport:181]
-2020-07-05 16:51:57.746| main | INFO |  -  | Mapped URL path [/v2/api-docs] onto method [springfox.documentation.swagger2.web.Swagger2Controller#getDocumentation(String, HttpServletRequest)] | [springfox.documentation.spring.web.PropertySourcedRequestMappingHandlerMapping:69]
-2020-07-05 16:51:58.922| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-group-session-wxapp_video', nameServer='127.0.0.1:9876', topic='themis-topic-session', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='wxapp_video', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:58.924| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketSessionConsumer$sessionConsumerWxappVideo, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_1 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:58.947| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-group-session-web', nameServer='127.0.0.1:9876', topic='themis-topic-session', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='web', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:58.948| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketSessionConsumer$sessionConsumerWeb, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_2 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:58.976| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-group-session-wxapp_answer', nameServer='127.0.0.1:9876', topic='themis-topic-session', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='wxapp_answer', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:58.977| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketSessionConsumer$sessionConsumerWxappAnswer, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_3 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:58.996| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-group-session-pc', nameServer='127.0.0.1:9876', topic='themis-topic-session', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='pc', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:58.997| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketSessionConsumer$sessionConsumerPc, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_4 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:59.011| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-group-userLog-user', nameServer='127.0.0.1:9876', topic='themis-topic-userLog', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='user', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:59.011| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketUserLogConsumer$sessionConsumerUserLog, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_5 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:59.028| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-tran-group', nameServer='127.0.0.1:9876', topic='themis-tran-topic', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='*', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:59.029| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketConsumerTranListener$consumerTranListener, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_6 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:59.043| main | INFO |  -  | running container: DefaultRocketMQListenerContainer{consumerGroup='themis-group-userLog-student', nameServer='127.0.0.1:9876', topic='themis-topic-userLog', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='student', messageModel=CLUSTERING} | [org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer:285]
-2020-07-05 16:51:59.043| main | INFO |  -  | Register the listener to container, listenerBeanName:com.qmth.themis.mq.listener.RocketUserLogConsumer$sessionConsumerStudentLog, containerBeanName:org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer_7 | [org.apache.rocketmq.spring.autoconfigure.ListenerContainerConfiguration:127]
-2020-07-05 16:51:59.089| main | INFO |  -  | Starting ProtocolHandler ["http-nio-6003"] | [org.apache.juli.logging.DirectJDKLog:173]
-2020-07-05 16:51:59.133| main | INFO |  -  | Tomcat started on port(s): 6003 (http) with context path '/task' | [org.springframework.boot.web.embedded.tomcat.TomcatWebServer:220]
-2020-07-05 16:51:59.137| main | INFO |  -  | Context refreshed | [springfox.documentation.spring.web.plugins.DocumentationPluginsBootstrapper:160]
-2020-07-05 16:51:59.158| main | INFO |  -  | Found 1 custom documentation plugin(s) | [springfox.documentation.spring.web.plugins.DocumentationPluginsBootstrapper:163]
-2020-07-05 16:51:59.236| main | INFO |  -  | Scanning for api listing references | [springfox.documentation.spring.web.scanners.ApiListingReferenceScanner:41]
-2020-07-05 16:51:59.260| main | INFO |  -  | Starting Quartz Scheduler now | [org.springframework.scheduling.quartz.SchedulerFactoryBean:727]
-2020-07-05 16:51:59.499| main | INFO |  -  | ClusterManager: detected 1 failed or restarted instances. | [org.quartz.impl.jdbcjobstore.JobStoreSupport:3644]
-2020-07-05 16:51:59.499| main | INFO |  -  | ClusterManager: Scanning for instance "kingdeMacBook-Air.local1593938904402"'s failed in-progress jobs. | [org.quartz.impl.jdbcjobstore.JobStoreSupport:3503]
-2020-07-05 16:51:59.510| main | INFO |  -  | Scheduler ClusterQuartz_$_kingdeMacBook-Air.local1593939113089 started. | [org.quartz.core.QuartzScheduler:547]
-2020-07-05 16:51:59.528| QuartzScheduler_ClusterQuartz-kingdeMacBook-Air.local1593939113089_MisfireHandler | INFO |  -  | Handling 1 trigger(s) that missed their scheduled fire-time. | [org.quartz.impl.jdbcjobstore.JobStoreSupport:973]
-2020-07-05 16:51:59.543| main | INFO |  -  | Started ThemisTaskApplication in 12.578 seconds (JVM running for 14.698) | [org.springframework.boot.StartupInfoLogger:61]
-2020-07-05 16:51:59.546| main | INFO |  -  | 服务器启动时执行 start | [com.qmth.themis.task.start.StartRunning:34]
-2020-07-05 16:51:59.546| main | INFO |  -  | 增加mqjob start | [com.qmth.themis.task.start.StartRunning:35]
-2020-07-05 16:51:59.649| main | INFO |  -  | 增加mqjob end | [com.qmth.themis.task.start.StartRunning:40]
-2020-07-05 16:51:59.649| main | INFO |  -  | 服务器启动时执行 end | [com.qmth.themis.task.start.StartRunning:41]
-2020-07-05 16:52:00.057| arbitrateThreadPool1 | INFO |  -  | session_topic_job进来了 | [com.qmth.themis.task.quartz.MqJob:40]
-2020-07-05 16:52:00.058| arbitrateThreadPool2 | INFO |  -  | userLog_topic_job进来了 | [com.qmth.themis.task.quartz.MqJob:44]
-2020-07-05 16:53:00.022| arbitrateThreadPool3 | INFO |  -  | session_topic_job进来了 | [com.qmth.themis.task.quartz.MqJob:40]
-2020-07-05 16:53:00.022| arbitrateThreadPool4 | INFO |  -  | userLog_topic_job进来了 | [com.qmth.themis.task.quartz.MqJob:44]
-2020-07-05 16:54:00.020| arbitrateThreadPool5 | INFO |  -  | session_topic_job进来了 | [com.qmth.themis.task.quartz.MqJob:40]
-2020-07-05 16:54:00.020| arbitrateThreadPool6 | INFO |  -  | userLog_topic_job进来了 | [com.qmth.themis.task.quartz.MqJob:44]