<Netty>（二十七）（项目篇）Netty项目之客户端代码（maven+springboot+自定义注解+分库分表+Netty）
2018-03-21 20:33
537 查看
http://localhost:8001/sender?count=10浏览器的请求网址是这个
一，数据源配置
1.1，pom.xml配置
1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
2 <modelVersion>4.0.0</modelVersion>
3 <groupId>bhz.uts</groupId>
4 <artifactId>uts-sender</artifactId>
5 <version>0.0.1-SNAPSHOT</version>
6
7 <parent>
8 <groupId>org.springframework.boot</groupId>
9 <artifactId>spring-boot-starter-parent</artifactId>
10 <version>1.5.6.RELEASE</version>
11 <relativePath/> <!-- lookup parent from repository -->
12 </parent>
13
14 <properties>
15 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
16 <java.version>1.8</java.version>
17 <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
18 <java.version>1.8</java.version>
19 <commons-fileupload.version>1.2.2</commons-fileupload.version>
20 <commons-lang3.version>3.3.1</commons-lang3.version>
21 <commons-io.version>2.4</commons-io.version>
22 <commons-collections.version>3.2.2</commons-collections.version>
23 <fastjson.version>1.1.26</fastjson.version>
24 <mybatis.version>3.4.1</mybatis.version>
25 <mybatis-spring.version>1.3.0</mybatis-spring.version>
26 <druid.version>1.0.24</druid.version>
27 <activiti.version>5.21.0</activiti.version>
28 <cxf.version>3.0.0</cxf.version>
29 <cxf-rt.version>3.1.6</cxf-rt.version>
30 <oracle.version>7</oracle.version>
31 <fasterxml.uuid.version>3.1.4</fasterxml.uuid.version>
32 <github.miemiedev.version>1.2.17</github.miemiedev.version>
33 <common.codec.version>1.10</common.codec.version>
34 <servlet-api.version>3.1.0</servlet-api.version>
35 <kaptcha.version>2.3.2</kaptcha.version>
36 <org.codehaus.jackson.version>1.9.13</org.codehaus.jackson.version>
37 <poi-ooxml.version>3.9</poi-ooxml.version>
38 <commons-beanutils.version>1.9.3</commons-beanutils.version>
39 <pinyin4j.version>2.5.1</pinyin4j.version>
40 </properties>
41
42 <dependencies>
43 <!-- 添加SpringMvc、Web[TOMCAT] jar provided排除tomcat, 使用独立容器运行（非内嵌，当） -->
44 <dependency>
45 <groupId>org.springframework.boot</groupId>
46 <artifactId>spring-boot-starter-web</artifactId>
47 </dependency>
48 <dependency>
49 <groupId>org.springframework.boot</groupId>
50 <artifactId>spring-boot-starter-test</artifactId>
51 <scope>test</scope>
52 </dependency>
53 <dependency>
54 <groupId>org.springframework.boot</groupId>
55 <artifactId>spring-boot-starter-aop</artifactId>
56 </dependency>
57 <dependency>
58 <groupId>org.springframework.boot</groupId>
59 <artifactId>spring-boot-autoconfigure</artifactId>
60 </dependency>
61 <dependency>
62 <groupId>commons-fileupload</groupId>
63 <artifactId>commons-fileupload</artifactId>
64 <version>${commons-fileupload.version}</version>
65 </dependency>
66 <dependency>
67 <groupId>org.apache.commons</groupId>
68 <artifactId>commons-lang3</artifactId>
69 <version>${commons-lang3.version}</version>
70 </dependency>
71 <dependency>
72 <groupId>commons-io</groupId>
73 <artifactId>commons-io</artifactId>
74 <version>${commons-io.version}</version>
75 </dependency>
76 <dependency>
77 <groupId>commons-collections</groupId>
78 <artifactId>commons-collections</artifactId>
79 <version>${commons-collections.version}</version>
80 </dependency>
81 <dependency>
82 <groupId>commons-codec</groupId>
83 <artifactId>commons-codec</artifactId>
84 <version>${common.codec.version}</version>
85 </dependency>
86 <dependency>
87 <groupId>commons-beanutils</groupId>
88 <artifactId>commons-beanutils</artifactId>
89 <version>${commons-beanutils.version}</version>
90 </dependency>
91 <dependency>
92 <groupId>com.alibaba</groupId>
93 <artifactId>fastjson</artifactId>
94 <version>${fastjson.version}</version>
95 </dependency>
96 <!--对json格式的支持 -->
97 <dependency>
98 <groupId>org.codehaus.jackson</groupId>
99 <artifactId>jackson-mapper-asl</artifactId>
100 <version>${org.codehaus.jackson.version}</version>
101 </dependency>
102 <dependency>
103 <groupId>com.fasterxml.jackson.core</groupId>
104 <artifactId>jackson-databind</artifactId>
105 </dependency>
106 <dependency>
107 <groupId>com.fasterxml.uuid</groupId>
108 <artifactId>java-uuid-generator</artifactId>
109 <version>${fasterxml.uuid.version}</version>
110 </dependency>
111 <!-- 添加JDBC jar -->
112 <dependency>
113 <groupId>org.springframework.boot</groupId>
114 <artifactId>spring-boot-starter-jdbc</artifactId>
115 </dependency>
116 <dependency>
117 <groupId>org.mybatis.spring.boot</groupId>
118 <artifactId>mybatis-spring-boot-starter</artifactId>
119 <version>1.1.1</version>
120 </dependency>
121 <dependency>
122 <groupId>tk.mybatis</groupId>
123 <artifactId>mapper-spring-boot-starter</artifactId>
124 <version>1.1.0</version>
125 </dependency>
126 <dependency>
127 <groupId>com.alibaba</groupId>
128 <artifactId>druid</artifactId>
129 <version>${druid.version}</version>
130 </dependency>
131 <dependency>
132 <groupId>mysql</groupId>
133 <artifactId>mysql-connector-java</artifactId>
134 </dependency>
135 <dependency>
136 <groupId>com.github.pagehelper</groupId>
137 <artifactId>pagehelper-spring-boot-starter</artifactId>
138 <version>1.1.0</version>
139 <exclusions>
140 <exclusion>
141 <artifactId>mybatis-spring-boot-starter</artifactId>
142 <groupId>org.mybatis.spring.boot</groupId>
143 </exclusion>
144 </exclusions>
145 </dependency>
146 <!-- netty -->
147 <dependency>
148 <groupId>io.netty</groupId>
149 <artifactId>netty-all</artifactId>
150 <version>4.1.12.Final</version>
151 </dependency>
152 <!-- 序列化框架marshalling -->
153 <dependency>
154 <groupId>org.jboss.marshalling</groupId>
155 <artifactId>jboss-marshalling</artifactId>
156 <version>1.3.0.CR9</version>
157 </dependency>
158 <dependency>
159 <groupId>org.jboss.marshalling</groupId>
160 <artifactId>jboss-marshalling-serial</artifactId>
161 <version>1.3.0.CR9</version>
162 </dependency>
163 <!-- netty end -->
164 </dependencies>
165
166 <build>
167 <finalName>uts-sender</finalName>
168 <!-- 打包时包含properties、xml -->
169 <resources>
170 <resource>
171 <directory>src/main/java</directory>
172 <includes>
173 <include>**/*.properties</include>
174 <include>**/*.xml</include>
175 </includes>
176 <!-- 是否替换资源中的属性-->
177 <filtering>true</filtering>
178 </resource>
179 <resource>
180 <directory>src/main/resources</directory>
181 </resource>
182 </resources>
183 <plugins>
184 <plugin>
185 <groupId>org.apache.maven.plugins</groupId>
186 <artifactId>maven-war-plugin</artifactId>
187 </plugin>
188 <!-- 解解决maven update project 后版本降低为1.5的bug -->
189 <plugin>
190 <groupId>org.apache.maven.plugins</groupId>
191 <artifactId>maven-compiler-plugin</artifactId>
192 <configuration>
193 <source>1.8</source>
194 <target>1.8</target>
195 </configuration>
196 </plugin>
197 <!-- 单元测试 -->
198 <plugin>
199 <groupId>org.apache.maven.plugins</groupId>
200 <artifactId>maven-surefire-plugin</artifactId>
201 <configuration>
202 <skip>true</skip>
203 <includes>
204 <include>**/*Test*.java</include>
205 </includes>
206 <testFailureIgnore>true</testFailureIgnore>
207 </configuration>
208 </plugin>
209 <plugin>
210 <groupId>org.apache.maven.plugins</groupId>
211 <artifactId>maven-source-plugin</artifactId>
212 <executions>
213 <!-- 绑定到特定的生命周期之后，运行maven-source-pluin 运行目标为jar-no-fork -->
214 <execution>
215 <phase>package</phase>
216 <goals>
217 <goal>jar-no-fork</goal>
218 </goals>
219 </execution>
220 </executions>
221 </plugin>
222 </plugins>
223 </build>
224
225 </project>
1.2，application.yml配置
1 server: 2 context-path: / 3 port: 8001 4 5 6 transfer: 7 host: 127.0.0.1 8 port: 8765 9 10 ## Spring配置: 11 spring: 12 http: 13 encoding: 14 charset: UTF-8 15 jackson: 16 date-format: yyyy-MM-dd HH:mm:ss 17 time-zone: GMT+8 18 default-property-inclusion: NON_NULL 19 ##DATASOURCE CONFIGURATION -- see druid.yml 20 datasource: 21 type: com.alibaba.druid.pool.DruidDataSource 22 url: jdbc:mysql://localhost:3306/uts-sender?characterEncoding=UTF-8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&useUnicode=true 23 driver-class-name: com.mysql.jdbc.Driver 24 username: root 25 password: root 26 27 28 mybatis: 29 type-aliases-package: bhz.uts 30 mapper-locations: classpath:bhz/uts/mapping/*.xml 31 32 logging: 33 level: 34 tk.mybatis: TRACE 35 36 37 pagehelper: 38 helperDialect: mysql 39 reasonable: true 40 supportMethodsArguments: true 41 params: count=countSql 42 43 44 45
druid.properties
1 ##下面为连接池的补充设置，应用到上面所有数据源中 2 #初始化大小，最小，最大 3 druid.initialSize=50 4 druid.minIdle=10 5 druid.maxIdle=10 6 druid.maxActive=500 7 #配置获取连接等待超时的时间 8 druid.maxWait=60000 9 #配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 10 druid.timeBetweenEvictionRunsMillis=60000 11 #配置一个连接在池中最小生存的时间，单位是毫秒 12 druid.minEvictableIdleTimeMillis=300000 13 druid.validationQuery=SELECT 1 FROM DUAL 14 druid.testWhileIdle=true 15 druid.testOnBorrow=false 16 druid.testOnReturn=false 17 #打开PSCache，并且指定每个连接上PSCache的大小 18 druid.poolPreparedStatements=true 19 druid.maxPoolPreparedStatementPerConnectionSize=20 20 #配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙 21 druid.filters=stat,wall,log4j 22 #通过connectProperties属性来打开mergeSql功能；慢SQL记录 23 druid.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000 24 #合并多个DruidDataSource的监控数据 25 druid.useGlobalDataSourceStat=true
1.3，数据库sql语句
1 /*==============================================================*/ 2 /* DBMS name: MySQL 5.0 */ 3 /* Created on: 2017/9/1 21:40:47 */ 4 /*==============================================================*/ 5 6 7 drop table if exists TRADE_DETAIL; 8 9 /*==============================================================*/ 10 /* Table: TRADE_DETAIL */ 11 /*==============================================================*/ 12 create table TRADE_DETAIL 13 ( 14 ID varchar(128) not null, 15 SERIALNO varchar(128) not null, 16 TRADE_DATE timestamp not null, 17 DEDBIT_AMOUNT numeric(20,2) not null, 18 CREDIT_AMOUNT numeric(20,2) not null, 19 BUSINESS_TYPE varchar(40) not null, 20 BALANCE numeric(20,2) not null, 21 OPP_ACCOUNT_NAME varchar(40) not null, 22 OPP_ACCOUNT_NO varchar(40) not null, 23 ACCOUNT_NAME varchar(40) not null, 24 ACCOUNT_NO varchar(40) not null, 25 DIGEST varchar(400), 26 STATUS varchar(1) not null, 27 CREATE_BY varchar(40) not null, 28 CREATE_TIME timestamp not null, 29 UPDATE_BY varchar(40) not null, 30 UPDATE_TIME timestamp not null, 31 primary key (ID) 32 );
1.4，BaseMapper.java（基础扫描类）
1 package bhz.uts.config.database;
2
3
4 import tk.mybatis.mapper.common.Mapper;
5 import tk.mybatis.mapper.common.MySqlMapper;
6 /**
7 * <B>系统名称：</B><BR>
8 * <B>模块名称：</B>base-sys<BR>
9 * <B>中文类名：</B>BaseMapper<BR>
10 * <B>概要说明：</B>基础数据库服务<BR>
11 * @author bhz
12 * @since 2017年2月8日 下午2:42:49
13 */
14 public interface BaseMapper<T> extends Mapper<T>, MySqlMapper<T> {
15
16 }
1.5,DruidDataSourceSettings.java(数据源注入类，这个类只负责把配置文件中的数据源的东西加载到相应的属性中来)
1 package bhz.uts.config.database;
2
3 import org.springframework.beans.factory.annotation.Value;
4 import org.springframework.boot.context.properties.ConfigurationProperties;
5 import org.springframework.context.annotation.Bean;
6 import org.springframework.context.annotation.PropertySource;
7 import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
8 import org.springframework.stereotype.Component;
9
10 @Component
11 @ConfigurationProperties(prefix="spring.datasource")
12 @PropertySource("classpath:druid.properties")
13 public class DruidDataSourceSettings {
14
15 private String driverClassName;
16 private String url;
17 private String username;
18 private String password;
19
20 @Value("${druid.initialSize}")
21 private int initialSize;
22
23 @Value("${druid.minIdle}")
24 private int minIdle;
25
26 @Value("${druid.maxIdle}")
27 private int maxIdle;
28
29 @Value("${druid.maxActive}")
30 private int maxActive;
31
32 @Value("${druid.timeBetweenEvictionRunsMillis}")
33 private long timeBetweenEvictionRunsMillis;
34
35 @Value("${druid.minEvictableIdleTimeMillis}")
36 private long minEvictableIdleTimeMillis;
37
38 @Value("${druid.validationQuery}")
39 private String validationQuery;
40
41 @Value("${druid.testWhileIdle}")
42 private boolean testWhileIdle;
43
44 @Value("${druid.testOnBorrow}")
45 private boolean testOnBorrow;
46
47 @Value("${druid.testOnReturn}")
48 private boolean testOnReturn;
49
50 @Value("${druid.poolPreparedStatements}")
51 private boolean poolPreparedStatements;
52
53 @Value("${druid.maxPoolPreparedStatementPerConnectionSize}")
54 private int maxPoolPreparedStatementPerConnectionSize;
55
56 @Value("${druid.filters}")
57 private String filters;
58
59 @Value("${druid.connectionProperties}")
60 private String connectionProperties;
61
62 @Bean
63 public static PropertySourcesPlaceholderConfigurer properdtyConfigure(){
64 return new PropertySourcesPlaceholderConfigurer();
65 }
66
67 public String getDriverClassName() {
68 return driverClassName;
69 }
70 public void setDriverClassName(String driverClassName) {
71 this.driverClassName = driverClassName;
72 }
73 public String getUrl() {
74 return url;
75 }
76 public void setUrl(String url) {
77 this.url = url;
78 }
79 public String getUsername() {
80 return username;
81 }
82 public void setUsername(String username) {
83 this.username = username;
84 }
85 public String getPassword() {
86 return password;
87 }
88 public void setPassword(String password) {
89 this.password = password;
90 }
91 public int getInitialSize() {
92 return initialSize;
93 }
94 public void setInitialSize(int initialSize) {
95 this.initialSize = initialSize;
96 }
97 public int getMinIdle() {
98 return minIdle;
99 }
100 public void setMinIdle(int minIdle) {
101 this.minIdle = minIdle;
102 }
103 public int getMaxIdle() {
104 return maxIdle;
105 }
106 public void setMaxIdle(int maxIdle) {
107 this.maxIdle = maxIdle;
108 }
109 public int getMaxActive() {
110 return maxActive;
111 }
112 public void setMaxActive(int maxActive) {
113 this.maxActive = maxActive;
114 }
115 public long getTimeBetweenEvictionRunsMillis() {
116 return timeBetweenEvictionRunsMillis;
117 }
118 public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) {
119 this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
120 }
121 public long getMinEvictableIdleTimeMillis() {
122 return minEvictableIdleTimeMillis;
123 }
124 public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) {
125 this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
126 }
127 public String getValidationQuery() {
128 return validationQuery;
129 }
130 public void setValidationQuery(String validationQuery) {
131 this.validationQuery = validationQuery;
132 }
133 public boolean isTestWhileIdle() {
134 return testWhileIdle;
135 }
136 public void setTestWhileIdle(boolean testWhileIdle) {
137 this.testWhileIdle = testWhileIdle;
138 }
139 public boolean isTestOnBorrow() {
140 return testOnBorrow;
141 }
142 public void setTestOnBorrow(boolean testOnBorrow) {
143 this.testOnBorrow = testOnBorrow;
144 }
145 public boolean isTestOnReturn() {
146 return testOnReturn;
147 }
148 public void setTestOnReturn(boolean testOnReturn) {
149 this.testOnReturn = testOnReturn;
150 }
151 public boolean isPoolPreparedStatements() {
152 return poolPreparedStatements;
153 }
154 public void setPoolPreparedStatements(boolean poolPreparedStatements) {
155 this.poolPreparedStatements = poolPreparedStatements;
156 }
157 public int getMaxPoolPreparedStatementPerConnectionSize() {
158 return maxPoolPreparedStatementPerConnectionSize;
159 }
160 public void setMaxPoolPreparedStatementPerConnectionSize(
161 int maxPoolPreparedStatementPerConnectionSize) {
162 this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;
163 }
164 public String getFilters() {
165 return filters;
166 }
167 public void setFilters(String filters) {
168 this.filters = filters;
169 }
170 public String getConnectionProperties() {
171 return connectionProperties;
172 }
173 public void setConnectionProperties(String connectionProperties) {
174 this.connectionProperties = connectionProperties;
175 }
176
177 }
1.6，MybatisDataSourceConfig.java（注入工厂类）
1 /**
2 * Copyright 2017 JINZAY All Rights Reserved.
3 */
4 package bhz.uts.config.database;
5
6 import javax.sql.DataSource;
7
8 import org.apache.ibatis.session.SqlSessionFactory;
9 import org.mybatis.spring.SqlSessionFactoryBean;
10 import org.mybatis.spring.SqlSessionTemplate;
11 import org.springframework.beans.factory.annotation.Autowired;
12 import org.springframework.context.annotation.Bean;
13 import org.springframework.context.annotation.Configuration;
14 import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
15 import org.springframework.core.io.support.ResourcePatternResolver;
16
17 @Configuration
18 public class MybatisDataSourceConfig {
19
20 @Autowired
21 private DataSource dataSource;
22
23 @Bean(name="sqlSessionFactory")
24 public SqlSessionFactory sqlSessionFactoryBean() {
25 SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
26 bean.setDataSource(dataSource);
27 // 添加XML目录
28 ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
29 try {
30 bean.setMapperLocations(resolver.getResources("classpath:bhz/uts/mapping/*.xml"));
31 SqlSessionFactory sqlSessionFactory = bean.getObject();
32 sqlSessionFactory.getConfiguration().setCacheEnabled(Boolean.TRUE);
33
34 return sqlSessionFactory;
35 } catch (Exception e) {
36 throw new RuntimeException(e);
37 }
38 }
39
40 @Bean
41 public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
42 return new SqlSessionTemplate(sqlSessionFactory);
43 }
44
45 }
1.7，MybatisMapperScanerConfig.java（扫描数据源类）
1 package bhz.uts.config.database;
2
3 import org.mybatis.spring.mapper.MapperScannerConfigurer;
4 import org.springframework.boot.autoconfigure.AutoConfigureAfter;
5 import org.springframework.context.annotation.Bean;
6 import org.springframework.context.annotation.Configuration;
7
8 @Configuration
9 @AutoConfigureAfter(MybatisDataSourceConfig.class)
10 public class MybatisMapperScanerConfig {
11
12 @Bean
13 public MapperScannerConfigurer mapperScannerConfigurer() {
14 MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer();
15 mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");
16 mapperScannerConfigurer.setBasePackage("bhz.uts.mapper");
17 return mapperScannerConfigurer;
18 }
19
20 }
1.8，封装数据源类（这个类负责从容器中来取到数据并设置到dataSource对象中来）
1 package bhz.uts.config.database;
2
3 import java.sql.SQLException;
4
5 import javax.sql.DataSource;
6
7 import org.slf4j.Logger;
8 import org.slf4j.LoggerFactory;
9 import org.springframework.beans.factory.annotation.Autowired;
10 import org.springframework.boot.web.servlet.FilterRegistrationBean;
11 import org.springframework.boot.web.servlet.ServletRegistrationBean;
12 import org.springframework.context.annotation.Bean;
13 import org.springframework.context.annotation.Configuration;
14 import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
15 import org.springframework.jdbc.datasource.DataSourceTransactionManager;
16 import org.springframework.transaction.PlatformTransactionManager;
17 import org.springframework.transaction.annotation.EnableTransactionManagement;
18
19 import com.alibaba.druid.pool.DruidDataSource;
20 import com.alibaba.druid.support.http.StatViewServlet;
21 import com.alibaba.druid.support.http.WebStatFilter;
22
23 @Configuration
24 @EnableTransactionManagement
25 public class DruidDataSourceConfig {
26
27 private static Logger logger = LoggerFactory.getLogger(DruidDataSourceConfig.class);
28
29 @Autowired
30 private DruidDataSourceSettings druidSettings;
31
32 public static String DRIVER_CLASSNAME ;
33
34 @Bean
35 public static PropertySourcesPlaceholderConfigurer propertyConfigure(){
36 return new PropertySourcesPlaceholderConfigurer();
37 }
38 //扫描类
39 @Bean
40 public ServletRegistrationBean druidServlet() {
41
42 ServletRegistrationBean reg = new ServletRegistrationBean();
43 reg.setServlet(new StatViewServlet());
44 // reg.setAsyncSupported(true);
45 reg.addUrlMappings("/druid/*");
46 reg.addInitParameter("allow", "127.0.0.1");
47 // reg.addInitParameter("deny","/deny");
48 reg.addInitParameter("loginUsername", "bhz");
49 reg.addInitParameter("loginPassword", "bhz");
50 logger.info(" druid console manager init : {} ", reg);
51 return reg;
52 }
53 //扫描类
54 @Bean
55 public FilterRegistrationBean filterRegistrationBean() {
56 FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
57 filterRegistrationBean.setFilter(new WebStatFilter());
58 filterRegistrationBean.addUrlPatterns("/*");
59 filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico, /druid/*");
60 logger.info(" druid filter register : {} ", filterRegistrationBean);
61 return filterRegistrationBean;
62 }
63
64 @Bean
65 public DataSource dataSource() throws SQLException {
66 DruidDataSource ds = new DruidDataSource();
67 ds.setDriverClassName(druidSettings.getDriverClassName());
68 DRIVER_CLASSNAME = druidSettings.getDriverClassName();
69 ds.setUrl(druidSettings.getUrl());
70 ds.setUsername(druidSettings.getUsername());
71 ds.setPassword(druidSettings.getPassword());
72 ds.setInitialSize(druidSettings.getInitialSize());
73 ds.setMinIdle(druidSettings.getMinIdle());
74 ds.setMaxIdle(druidSettings.getMaxIdle());
75 ds.setMaxActive(druidSettings.getMaxActive());
76 ds.setTimeBetweenEvictionRunsMillis(druidSettings.getTimeBetweenEvictionRunsMillis());
77 ds.setMinEvictableIdleTimeMillis(druidSettings.getMinEvictableIdleTimeMillis());
78 ds.setValidationQuery(druidSettings.getValidationQuery());
79 ds.setTestWhileIdle(druidSettings.isTestWhileIdle());
80 ds.setTestOnBorrow(druidSettings.isTestOnBorrow());
81 ds.setTestOnReturn(druidSettings.isTestOnReturn());
82 ds.setPoolPreparedStatements(druidSettings.isPoolPreparedStatements());
83 ds.setMaxPoolPreparedStatementPerConnectionSize(druidSettings.getMaxPoolPreparedStatementPerConnectionSize());
84 ds.setFilters(druidSettings.getFilters());
85 ds.setConnectionProperties(druidSettings.getConnectionProperties());
86
87 //proxyFilters ===> 有问题
88 // WallFilter wallFilter = new WallFilter();
89 // WallConfig wallConfig = new WallConfig();
90 // wallConfig.setMultiStatementAllow(true);
91 // wallFilter.setConfig(wallConfig);
92 // List<Filter> wallFilterList = new ArrayList<Filter>();
93 // wallFilterList.add(wallFilter);
94 // ds.setProxyFilters(wallFilterList);
95 logger.info(" druid datasource config : {} ", ds);
96 return ds;
97 }
98 //事务方法
99 @Bean
100 public PlatformTransactionManager transactionManager() throws Exception {
101 DataSourceTransactionManager txManager = new DataSourceTransactionManager();
102 txManager.setDataSource(dataSource());
103 return txManager;
104 }
105
106 }
二，任务时间控制类（在本项目中没有用到）
2.1，TaskSchedulerConfig.java
1 package bhz.uts.config.scheduler;
2
3 import java.util.concurrent.Executor;
4 import java.util.concurrent.Executors;
5
6 import org.springframework.context.annotation.Bean;
7 import org.springframework.context.annotation.Configuration;
8 import org.springframework.scheduling.annotation.EnableScheduling;
9 import org.springframework.scheduling.annotation.SchedulingConfigurer;
10 import org.springframework.scheduling.config.ScheduledTaskRegistrar;
11
12 @Configuration
13 @EnableScheduling
14 public class TaskSchedulerConfig implements SchedulingConfigurer {
15
16 @Override
17 public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
18 scheduledTaskRegistrar.setScheduler(taskScheduler());
19 }
20
21 @Bean(destroyMethod="shutdown")
22 public Executor taskScheduler(){
23 return Executors.newScheduledThreadPool(100);
24 }
25
26 }
三，实体类
3.1，BaseEntity.java
1 package bhz.uts.entity;
2
3 public class BaseEntity {
4
5 private String id;
6
7 public String getId() {
8 return id;
9 }
10
11 public void setId(String id) {
12 this.id = id;
13 }
14
15
16 }
3.2,TradeDetail.java
1 package bhz.uts.entity;
2
3 import java.math.BigDecimal;
4 import java.util.Date;
5
6 public class TradeDetail extends BaseEntity {
7
8 private String serialno;
9
10 private Date tradeDate;
11
12 private BigDecimal dedbitAmount;
13
14 private BigDecimal creditAmount;
15
16 private String businessType;
17
18 private BigDecimal balance;
19
20 private String oppAccountName;
21
22 private String oppAccountNo;
23
24 private String accountName;
25
26 private String accountNo;
27
28 private String digest;
29
30 private String status;
31
32 private String createBy;
33
34 private Date createTime;
35
36 private String updateBy;
37
38 private Date updateTime;
39
40 public String getSerialno() {
41 return serialno;
42 }
43
44 public void setSerialno(String serialno) {
45 this.serialno = serialno == null ? null : serialno.trim();
46 }
47
48 public Date getTradeDate() {
49 return tradeDate;
50 }
51
52 public void setTradeDate(Date tradeDate) {
53 this.tradeDate = tradeDate;
54 }
55
56 public BigDecimal getDedbitAmount() {
57 return dedbitAmount;
58 }
59
60 public void setDedbitAmount(BigDecimal dedbitAmount) {
61 this.dedbitAmount = dedbitAmount;
62 }
63
64 public BigDecimal getCreditAmount() {
65 return creditAmount;
66 }
67
68 public void setCreditAmount(BigDecimal creditAmount) {
69 this.creditAmount = creditAmount;
70 }
71
72 public String getBusinessType() {
73 return businessType;
74 }
75
76 public void setBusinessType(String businessType) {
77 this.businessType = businessType;
78 }
79
80 public BigDecimal getBalance() {
81 return balance;
82 }
83
84 public void setBalance(BigDecimal balance) {
85 this.balance = balance;
86 }
87
88 public String getOppAccountName() {
89 return oppAccountName;
90 }
91
92 public void setOppAccountName(String oppAccountName) {
93 this.oppAccountName = oppAccountName == null ? null : oppAccountName.trim();
94 }
95
96 public String getOppAccountNo() {
97 return oppAccountNo;
98 }
99
100 public void setOppAccountNo(String oppAccountNo) {
101 this.oppAccountNo = oppAccountNo == null ? null : oppAccountNo.trim();
102 }
103
104 public String getAccountName() {
105 return accountName;
106 }
107
108 public void setAccountName(String accountName) {
109 this.accountName = accountName;
110 }
111
112 public String getAccountNo() {
113 return accountNo;
114 }
115
116 public void setAccountNo(String accountNo) {
117 this.accountNo = accountNo == null ? null : accountNo.trim();
118 }
119
120 public String getDigest() {
121 return digest;
122 }
123
124 public void setDigest(String digest) {
125 this.digest = digest == null ? null : digest.trim();
126 }
127
128 public String getStatus() {
129 return status;
130 }
131
132 public void setStatus(String status) {
133 this.status = status == null ? null : status.trim();
134 }
135
136 public String getCreateBy() {
137 return createBy;
138 }
139
140 public void setCreateBy(String createBy) {
141 this.createBy = createBy == null ? null : createBy.trim();
142 }
143
144 public Date getCreateTime() {
145 return createTime;
146 }
147
148 public void setCreateTime(Date createTime) {
149 this.createTime = createTime;
150 }
151
152 public String getUpdateBy() {
153 return updateBy;
154 }
155
156 public void setUpdateBy(String updateBy) {
157 this.updateBy = updateBy == null ? null : updateBy.trim();
158 }
159
160 public Date getUpdateTime() {
161 return updateTime;
162 }
163
164 public void setUpdateTime(Date updateTime) {
165 this.updateTime = updateTime;
166 }
167 }
四，监听类
4.1,ApplicationFactory.java(容器类)
1 package bhz.uts.listener;
2
3 import org.springframework.beans.BeansException;
4 import org.springframework.context.ApplicationContext;
5 import org.springframework.context.ApplicationContextAware;
6 import org.springframework.stereotype.Component;
7 /**
8 * <B>系统名称：</B><BR>
9 * <B>模块名称：</B><BR>
10 * <B>中文类名：</B>ApplicationFactory<BR>
11 * <B>概要说明：</B><BR>
12 * @author baihezhuo
13 * @since 2017年5月27日 下午4:41:47
14 */
15 @Component
16 public class ApplicationFactory implements ApplicationContextAware {
17
18 private static ApplicationContext ctx = null;
19
20 @Override
21 public void setApplicationContext(ApplicationContext ctx) throws BeansException {
22 if (ApplicationFactory.ctx == null) {
23 ApplicationFactory.ctx = ctx;
24 }
25 }
26
27 // 获取applicationContext
28 public static ApplicationContext getApplicationContext() {
29 return ctx;
30 }
31
32 // 通过name获取 Bean.
33 public static Object getBean(String name) {
34 return getApplicationContext().getBean(name);
35 }
36
37 // 通过class获取Bean.
38 public static <T> T getBean(Class<T> clazz) {
39 return getApplicationContext().getBean(clazz);
40 }
41
42 // 通过name,以及Clazz返回指定的Bean
43 public static <T> T getBean(String name, Class<T> clazz) {
44 return getApplicationContext().getBean(name, clazz);
45 }
46
47
48 }
4.2,SpringListener.java（监控容器是否加载完的类）
1 package bhz.uts.listener;
2
3 import org.springframework.context.ApplicationListener;
4 import org.springframework.context.event.ContextRefreshedEvent;
5 import org.springframework.stereotype.Component;
6
7 import bhz.uts.netty.NettyClient;
8
9
10 @Component("springListener")
11 public class SpringListener implements ApplicationListener<ContextRefreshedEvent>{
12
13 @Override
14 public void onApplicationEvent(ContextRefreshedEvent event) {
15
16 if(event.getApplicationContext().getParent() == null){
17 //需要执行的逻辑代码，当spring容器初始化完成后就会执行该方法。
18 System.out.println("spring 加载完毕..");
19 try {
20 NettyClient.getInstance().connect();
21 } catch (Exception e) {
22 e.printStackTrace();
23 }
24 }
25
26
27
28 }
29
30
31
32 }
spring容器加载好了之后在启动服务器端的链接
五，mapper类
5.1，TradeDetailMapper.java
1 package bhz.uts.mapper;
2
3 import java.util.List;
4
5 import org.apache.ibatis.annotations.Param;
6
7 import bhz.uts.config.database.BaseMapper;
8 import bhz.uts.entity.TradeDetail;
9
10 public interface TradeDetailMapper extends BaseMapper<TradeDetail> {
11
12 int updateStatusById(@Param("id")String id);
13
14 List<TradeDetail> queryByNotSync();
15
16 }
5.2，TradeDetailMapper.xml
1 <?xml version="1.0" encoding="UTF-8" ?>
2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
3 <mapper namespace="bhz.uts.mapper.TradeDetailMapper" >
4 <resultMap id="BaseResultMap" type="bhz.uts.entity.TradeDetail" >
5 <id column="ID" property="id" jdbcType="VARCHAR" />
6 <result column="SERIALNO" property="serialno" jdbcType="VARCHAR" />
7 <result column="TRADE_DATE" property="tradeDate" jdbcType="TIMESTAMP" />
8 <result column="DEDBIT_AMOUNT" property="dedbitAmount" jdbcType="DECIMAL" />
9 <result column="CREDIT_AMOUNT" property="creditAmount" jdbcType="DECIMAL" />
10 <result column="BUSINESS_TYPE" property="businessType" jdbcType="VARCHAR" />
11 <result column="BALANCE" property="balance" jdbcType="DECIMAL" />
12 <result column="OPP_ACCOUNT_NAME" property="oppAccountName" jdbcType="VARCHAR" />
13 <result column="OPP_ACCOUNT_NO" property="oppAccountNo" jdbcType="VARCHAR" />
14 <result column="ACCOUNT_NAME" property="accountName" jdbcType="VARCHAR" />
15 <result column="ACCOUNT_NO" property="accountNo" jdbcType="VARCHAR" />
16 <result column="DIGEST" property="digest" jdbcType="VARCHAR" />
17 <result column="STATUS" property="status" jdbcType="VARCHAR" />
18 <result column="CREATE_BY" property="createBy" jdbcType="VARCHAR" />
19 <result column="CREATE_TIME" property="createTime" jdbcType="TIMESTAMP" />
20 <result column="UPDATE_BY" property="updateBy" jdbcType="VARCHAR" />
21 <result column="UPDATE_TIME" property="updateTime" jdbcType="TIMESTAMP" />
22 </resultMap>
23 <sql id="Base_Column_List" >
24 ID, SERIALNO, TRADE_DATE, DEDBIT_AMOUNT, CREDIT_AMOUNT, BUSINESS_TYPE, BALANCE, OPP_ACCOUNT_NAME,
25 OPP_ACCOUNT_NO, ACCOUNT_NAME, ACCOUNT_NO, DIGEST, STATUS, CREATE_BY, CREATE_TIME,
26 UPDATE_BY, UPDATE_TIME
27 </sql>
28
29 <update id="updateStatusById" >
30 UPDATE TRADE_DETAIL SET STATUS = 1 WHERE ID = #{id,jdbcType=VARCHAR}
31 </update>
32
33 <select id="queryByNotSync" resultMap="BaseResultMap" >
34 SELECT * FROM TRADE_DETAIL WHERE STATUS = 0
35 </select>
36
37 </mapper>
六，service类
6.1，TradeDetailService.java
1 package bhz.uts.service;
2
3 import org.springframework.beans.factory.annotation.Autowired;
4 import org.springframework.stereotype.Service;
5 import org.springframework.transaction.annotation.Transactional;
6
7 import com.alibaba.fastjson.JSONObject;
8
9 import bhz.uts.entity.TradeDetail;
10 import bhz.uts.mapper.TradeDetailMapper;
11 import bhz.uts.netty.NettyClient;
12 import bhz.uts.protocol.Req;
13 import bhz.uts.utils.Const;
14 import io.netty.channel.ChannelFuture;
15
16 @Service
17 public class TradeDetailService {
18
19
20 @Autowired
21 private TradeDetailMapper tradeDetailMapper;
22
23 @Transactional
24 public void sender(TradeDetail td) {
25
26 //1 insert
27 tradeDetailMapper.insert(td);
28 //2 transfer
29 //3,从clent角度来看，3.1，先把数据设置到req对象中来，假如有信息返回的话在去执行channelfuture里面的内容
30 ChannelFuture cf = NettyClient.getInstance().getChannelFuture();
31 Req req = new Req();
32 req.setId(td.getId());
33 req.setReqeustMessage(JSONObject.toJSONString(td));
34 req.setTag(Const.TRADE_DETAIL);
35 req.setType(Const.SAVE);
36 cf.channel().writeAndFlush(req);
37
38 }
39
40 public int updateStatusById(String id) {
41 return tradeDetailMapper.updateStatusById(id);
42 }
43
44
45 }
加红色字体的就是最明显的异步非阻塞的代表，代码走到第30行的时候就会接着往下走，走31行的代码，而这时后开启的另一个线程就会去走第30行里面的数据，按照业务逻辑的话是31-36行和
group = new NioEventLoopGroup();
b = new Bootstrap();
b.group(group)
.channel(NioSocketChannel.class)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel sc) throws Exception {
sc.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingDecoder());
sc.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingEncoder());
sc.pipeline().addLast(new NettyClientHandler());
在前面的，只有它先在客户端把信息传递到服务端才会执行
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
try {
Resp resp = (Resp)msg;
String id = resp.getId();
String tag = resp.getTag();
String type = resp.getType();
String responseCode = resp.getResponseCode();
String responseMessage = resp.getResponseMessage();
这里面的代码的。
6.2，SenderTradeDetailController.java（浏览器调用类）
1 package bhz.uts.service.api;
2
3 import org.springframework.beans.factory.annotation.Autowired;
4 import org.springframework.web.bind.annotation.RequestMapping;
5 import org.springframework.web.bind.annotation.RequestParam;
6 import org.springframework.web.bind.annotation.RestController;
7
8 import bhz.uts.entity.TradeDetail;
9 import bhz.uts.service.TradeDetailService;
10 import bhz.uts.utils.GeneratorDataUtil;
11
12 @RestController
13 public class SenderTradeDetailController {
14
15 @Autowired
16 private TradeDetailService tradeDetailService;
17
18 @RequestMapping("/sender")
19 public void sender(@RequestParam("count") Integer count) throws Exception {
20
21 for(int i =0; i < count ; i ++){
22 TradeDetail td = GeneratorDataUtil.generator();
23 ///拿到数据以后， 调用service
24 tradeDetailService.sender(td);
25 }
26 }
27
28 }
http://localhost:8001/sender?count=10浏览器的请求网址是这个
七，编辑码的请求和相应类
7.1，Req.java
1 package bhz.uts.protocol;
2
3 import java.io.Serializable;
4
5 public class Req implements Serializable {
6
7
8 private static final long serialVersionUID = 1L;
9
10 private String id ; //唯一ID
11 private String type ; //操作类型
12 private String tag ; //传输对象的类型:::
13 private String reqeustMessage; //json对象
14 public String getId() {
15 return id;
16 }
17 public void setId(String id) {
18 this.id = id;
19 }
20 public String getType() {
21 return type;
22 }
23 public void setType(String type) {
24 this.type = type;
25 }
26 public String getTag() {
27 return tag;
28 }
29 public void setTag(String tag) {
30 this.tag = tag;
31 }
32 public String getReqeustMessage() {
33 return reqeustMessage;
34 }
35 public void setReqeustMessage(String reqeustMessage) {
36 this.reqeustMessage = reqeustMessage;
37 }
38
39
40
41
42
43
44
45
46 }
7.2，Resp.java
1 package bhz.uts.protocol;
2
3 import java.io.Serializable;
4
5 public class Resp implements Serializable {
6
7
8 private static final long serialVersionUID = 1L;
9
10 private String id;
11 private String type;
12 private String tag;
13 private String responseCode; //响应码::
14 private String responseMessage;
15
16
17 public String getId() {
18 return id;
19 }
20 public void setId(String id) {
21 this.id = id;
22 }
23 public String getType() {
24 return type;
25 }
26 public void setType(String type) {
27 this.type = type;
28 }
29 public String getTag() {
30 return tag;
31 }
32 public void setTag(String tag) {
33 this.tag = tag;
34 }
35 public String getResponseCode() {
36 return responseCode;
37 }
38 public void setResponseCode(String responseCode) {
39 this.responseCode = responseCode;
40 }
41 public String getResponseMessage() {
42 return responseMessage;
43 }
44 public void setResponseMessage(String responseMessage) {
45 this.responseMessage = responseMessage;
46 }
47
48
49
50
51 }
八，netty的客户端代码
8.1，MarshallingCodeCFactory.java（编解码类）
1 package bhz.uts.netty;
2
3 import io.netty.handler.codec.marshalling.DefaultMarshallerProvider;
4 import io.netty.handler.codec.marshalling.DefaultUnmarshallerProvider;
5 import io.netty.handler.codec.marshalling.MarshallerProvider;
6 import io.netty.handler.codec.marshalling.MarshallingDecoder;
7 import io.netty.handler.codec.marshalling.MarshallingEncoder;
8 import io.netty.handler.codec.marshalling.UnmarshallerProvider;
9
10 import org.jboss.marshalling.MarshallerFactory;
11 import org.jboss.marshalling.Marshalling;
12 import org.jboss.marshalling.MarshallingConfiguration;
13
14 /**
15 * Marshalling工厂
16 * @author（alienware）
17 * @since 2014-12-16
18 */
19 public final class MarshallingCodeCFactory {
20
21 /**
22 * 创建Jboss Marshalling解码器MarshallingDecoder
23 * @return MarshallingDecoder
24 */
25 public static MarshallingDecoder buildMarshallingDecoder() {
26 //首先通过Marshalling工具类的精通方法获取Marshalling实例对象 参数serial标识创建的是java序列化工厂对象。
27 final MarshallerFactory marshallerFactory = Marshalling.getProvidedMarshallerFactory("serial");
28 //创建了MarshallingConfiguration对象，配置了版本号为5
29 final MarshallingConfiguration configuration = new MarshallingConfiguration();
30 configuration.setVersion(5);
31 //根据marshallerFactory和configuration创建provider
32 UnmarshallerProvider provider = new DefaultUnmarshallerProvider(marshallerFactory, configuration);
33 //构建Netty的MarshallingDecoder对象，俩个参数分别为provider和单个消息序列化后的最大长度
34 MarshallingDecoder decoder = new MarshallingDecoder(provider, 1024 * 1024 * 1);
35 return decoder;
36 }
37
38 /**
39 * 创建Jboss Marshalling编码器MarshallingEncoder
40 * @return MarshallingEncoder
41 */
42 public static MarshallingEncoder buildMarshallingEncoder() {
43 final MarshallerFactory marshallerFactory = Marshalling.getProvidedMarshallerFactory("serial");
44 final MarshallingConfiguration configuration = new MarshallingConfiguration();
45 configuration.setVersion(5);
46 MarshallerProvider provider = new DefaultMarshallerProvider(marshallerFactory, configuration);
47 //构建Netty的MarshallingEncoder对象，MarshallingEncoder用于实现序列化接口的POJO对象序列化为二进制数组
48 MarshallingEncoder encoder = new MarshallingEncoder(provider);
49 return encoder;
50 }
51 }
8.2，NettyClient.java（客户端类）
1 package bhz.uts.netty;
2
3 import io.netty.bootstrap.Bootstrap;
4 import io.netty.channel.ChannelFuture;
5 import io.netty.channel.ChannelInitializer;
6 import io.netty.channel.EventLoopGroup;
7 import io.netty.channel.nio.NioEventLoopGroup;
8 import io.netty.channel.socket.SocketChannel;
9 import io.netty.channel.socket.nio.NioSocketChannel;
10
11 public class NettyClient {
12
13 private static class SingletionHolder {
14 static final NettyClient instance = new NettyClient();
15 }
16
17 public static NettyClient getInstance(){
18 return SingletionHolder.instance;
19 }
20
21 private String host = "127.0.0.1";
22
23 private int port = 8765;
24
25 private EventLoopGroup group;
26
27 private Bootstrap b;
28
29 private ChannelFuture cf;
30
31 private NettyClient(){
32 group = new NioEventLoopGroup();
33 b = new Bootstrap();
34 b.group(group)
35 .channel(NioSocketChannel.class)
36 .handler(new ChannelInitializer<SocketChannel>() {
37 @Override
38 protected void initChannel(SocketChannel sc) throws Exception {
39 sc.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingDecoder());
40 sc.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingEncoder());
41 sc.pipeline().addLast(new NettyClientHandler());
42 }
43 });
44 }
45
46 public void connect(){
47 try {
48 this.cf = this.b.connect(host, port).sync();
49 System.err.println("远程服务器端已经连接.. 可以进行数据通信....");
50 } catch (InterruptedException e) {
51 e.printStackTrace();
52 }
53 }
54
55 public void close(){
56 try {
57 this.cf.channel().closeFuture().sync();
58 this.group.shutdownGracefully();
59 } catch (InterruptedException e) {
60 e.printStackTrace();
61 }
62 }
63
64 public ChannelFuture getChannelFuture(){
65 if(this.cf == null) {
66 this.connect();
67 }
68 if(!this.cf.channel().isActive()){
69 this.connect();
70 }
71 return this.cf;
72 }
73
74
75 public String getHost() {
76 return host;
77 }
78
79 public void setHost(String host) {
80 this.host = host;
81 }
82
83 public int getPort() {
84 return port;
85 }
86
87 public void setPort(int port) {
88 this.port = port;
89 }
90
91
92
93
94
95 }
8.3，NettyClientHandler.java（实现类）
1 package bhz.uts.netty;
2
3 import bhz.uts.listener.ApplicationFactory;
4 import bhz.uts.protocol.Resp;
5 import bhz.uts.service.TradeDetailService;
6 import bhz.uts.utils.Const;
7 import io.netty.channel.ChannelHandlerContext;
8 import io.netty.channel.ChannelInboundHandlerAdapter;
9 import io.netty.util.ReferenceCountUtil;
10
11 public class NettyClientHandler extends ChannelInboundHandlerAdapter {
12
13 @Override
14 public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
15 try {
16
17 Resp resp = (Resp)msg;
18 String id = resp.getId();
19 String tag = resp.getTag();
20 String type = resp.getType();
21 String responseCode = resp.getResponseCode();
22 String responseMessage = resp.getResponseMessage();
23
24 if(Const.TRADE_DETAIL.equals(tag)){
25 TradeDetailService tradeDetailService = (TradeDetailService)ApplicationFactory.getBean("tradeDetailService");
26
27 if(Const.RESPONSE_CODE_OK.equals(responseCode)){
28 if(Const.UPDATE.equals(type)) {
29 System.err.println("更新同步标志-----------: id: " + id);
30 tradeDetailService.updateStatusById(id);
31 }
32 }
33 }
34
35 } finally {
36 ReferenceCountUtil.release(msg);
37 }
38
39 }
40
41
42 }
九，工具类
9.1，Const.java（常量类）
1 package bhz.uts.utils;
2
3 public final class Const {
4
5 public static final String TRADE_DETAIL = "trade_detail";
6 public static final String TRADE_BALANCE = "trade_balance";
7
8 public static final String QUERY = "query";
9 public static final String SAVE = "save";
10 public static final String UPDATE = "update";
11 public static final String DELETE = "delete";
12
13
14 public static final String RESPONSE_CODE_OK = "1";
15 public static final String RESPONSE_CODE_INSERT_ERR = "2";
16 public static final String RESPONSE_CODE_SERVER_ERR = "3";
17
18 }
9.2，FastJsonConvertUtil.java（json转化类）
1 package bhz.uts.utils;
2
3 import java.util.ArrayList;
4 import java.util.List;
5
6 import com.alibaba.fastjson.JSON;
7 import com.alibaba.fastjson.JSONObject;
8 import com.alibaba.fastjson.serializer.SerializerFeature;
9
10 /**
11 * <B>系统名称：</B>通用平台<BR>
12 * <B>模块名称：</B>通用平台-公共服务<BR>
13 * <B>中文类名：</B>通用平台-公共服务-FastJsonConvert<BR>
14 * <B>概要说明：</B><BR>
15 * @author bhz
16 * @since 2016年10月10日 上午11:01:52
17 */
18 public class FastJsonConvertUtil {
19
20 private static final SerializerFeature[] featuresWithNullValue = { SerializerFeature.WriteMapNullValue, SerializerFeature.WriteNullBooleanAsFalse,
21 SerializerFeature.WriteNullListAsEmpty, SerializerFeature.WriteNullNumberAsZero, SerializerFeature.WriteNullStringAsEmpty };
22
23 /**
24 * <B>方法名称：</B>将JSON字符串转换为实体对象<BR>
25 * <B>概要说明：</B>将JSON字符串转换为实体对象<BR>
26 * @param data JSON字符串
27 * @param clzss 转换对象
28 * @return T
29 */
30 public static <T> T convertJSONToObject(String data, Class<T> clzss) {
31 try {
32 T t = JSON.parseObject(data, clzss);
33 return t;
34 } catch (Exception e) {
35 e.printStackTrace();
36 return null;
37 }
38 }
39
40 /**
41 * <B>方法名称：</B>将JSONObject对象转换为实体对象<BR>
42 * <B>概要说明：</B>将JSONObject对象转换为实体对象<BR>
43 * @param data JSONObject对象
44 * @param clzss 转换对象
45 * @return T
46 */
47 public static <T> T convertJSONToObject(JSONObject data, Class<T> clzss) {
48 try {
49 T t = JSONObject.toJavaObject(data, clzss);
50 return t;
51 } catch (Exception e) {
52 e.printStackTrace();
53 return null;
54 }
55 }
56
57 /**
58 * <B>方法名称：</B>将JSON字符串数组转为List集合对象<BR>
59 * <B>概要说明：</B>将JSON字符串数组转为List集合对象<BR>
60 * @param data JSON字符串数组
61 * @param clzss 转换对象
62 * @return List<T>集合对象
63 */
64 public static <T> List<T> convertJSONToArray(String data, Class<T> clzss) {
65 try {
66 List<T> t = JSON.parseArray(data, clzss);
67 return t;
68 } catch (Exception e) {
69 e.printStackTrace();
70 return null;
71 }
72 }
73
74 /**
75 * <B>方法名称：</B>将List<JSONObject>转为List集合对象<BR>
76 * <B>概要说明：</B>将List<JSONObject>转为List集合对象<BR>
77 * @param data List<JSONObject>
78 * @param clzss 转换对象
79 * @return List<T>集合对象
80 */
81 public static <T> List<T> convertJSONToArray(List<JSONObject> data, Class<T> clzss) {
82 try {
83 List<T> t = new ArrayList<T>();
84 for (JSONObject jsonObject : data) {
85 t.add(convertJSONToObject(jsonObject, clzss));
86 }
87 return t;
88 } catch (Exception e) {
89 e.printStackTrace();
90 return null;
91 }
92 }
93
94 /**
95 * <B>方法名称：</B>将对象转为JSON字符串<BR>
96 * <B>概要说明：</B>将对象转为JSON字符串<BR>
97 * @param obj 任意对象
98 * @return JSON字符串
99 */
100 public static String convertObjectToJSON(Object obj) {
101 try {
102 String text = JSON.toJSONString(obj);
103 return text;
104 } catch (Exception e) {
105 e.printStackTrace();
106 return null;
107 }
108 }
109
110 /**
111 * <B>方法名称：</B>将对象转为JSONObject对象<BR>
112 * <B>概要说明：</B>将对象转为JSONObject对象<BR>
113 * @param obj 任意对象
114 * @return JSONObject对象
115 */
116 public static JSONObject convertObjectToJSONObject(Object obj){
117 try {
118 JSONObject jsonObject = (JSONObject) JSONObject.toJSON(obj);
119 return jsonObject;
120 } catch (Exception e) {
121 e.printStackTrace();
122 return null;
123 }
124 }
125
126
127 /**
128 * <B>方法名称：</B><BR>
129 * <B>概要说明：</B><BR>
130 * @param obj
131 * @return
132 */
133 public static String convertObjectToJSONWithNullValue(Object obj) {
134 try {
135 String text = JSON.toJSONString(obj, featuresWithNullValue);
136 return text;
137 } catch (Exception e) {
138 e.printStackTrace();
139 return null;
140 }
141 }
142
143 public static void main(String[] args) {
144 System.err.println(System.getProperties());
145 }
146 }
9.3，GeneratorDataUtil.java（造数据的类）
1 package bhz.uts.utils;
2
3 import java.math.BigDecimal;
4 import java.text.SimpleDateFormat;
5 import java.util.Date;
6 import java.util.Random;
7 import java.util.UUID;
8
9 import bhz.uts.entity.TradeDetail;
10
11 public class GeneratorDataUtil {
12
13 private static Random random = new Random();
14
15 //交易时间：
16 private static Date getRandomDate(){
17 SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
18 Date d = new Date(117,
19 random.nextInt(7),
20 (int)(Math.random()*28)+1,
21 (int)(Math.random()*23)+1,
22 (int)(Math.random()*59)+1,
23 (int)(Math.random()*59)+1);
24 System.out.println(formatter.format(d));
25 return d;
26 }
27
28 static Object[] accounts = null;
29 static {
30 Pair p1 = new Pair<String, String>("张三", "30001040191113380583");
31 Pair p2 = new Pair<String, String>("李四", "40003242903000023274");
32 Pair p3 = new Pair<String, String>("王五", "50033457780002320965");
33 Pair p4 = new Pair<String, String>("赵六", "68886000080002320926");
34 accounts = new Object[]{p1, p2, p3, p4};
35 }
36
37 static Object[] oppAccounts = null;
38 static {
39 Pair p1 = new Pair<String, String>("小1", "500013334380543599");
40 Pair p2 = new Pair<String, String>("小2", "498980000566599998");
41 Pair p3 = new Pair<String, String>("小3", "788876699990005589");
42 Pair p4 = new Pair<String, String>("小4", "155500006660007779");
43 Pair p5 = new Pair<String, String>("小5", "344339999333000001");
44 oppAccounts = new Object[]{p1, p2, p3, p4, p5};
45 }
46
47 //
48 private static String generateSerialno(Date d){
49 SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd");
50 StringBuffer key = new StringBuffer();
51 key.append(formatter.format(d));
52 String uid = UUID.randomUUID().toString().replaceAll("-", "").toUpperCase();
53 key.append(uid.substring(12));
54 return key.toString();
55 }
56
57 //
58 private static Pair getRandomAccounts(){
59 return (Pair) accounts[random.nextInt(accounts.length)];
60 }
61
62 private static Pair getRandomOppAccounts(){
63 return (Pair) oppAccounts[random.nextInt(oppAccounts.length)];
64 }
65
66
67 static Object[] digests = null;
68 static {
69 String d1 = "转账";
70 String d2 = "付款";
71 String d3 = "百度买单";
72 String d4 = "美团买单";
73 String d5 = "淘宝买单";
74 digests = new Object[]{d1, d2, d3, d4, d5};
75 }
76
77 private static String getRandomDigest(){
78 return (String) digests[random.nextInt(digests.length)];
79 }
80
81 public static void main(String[] args) {
82 System.err.println(getRandomBalance());
83 }
84
85 private static int getRandomCreditAmount(){
86 return (int) ((Math.random()*100)+ (Math.random()*300) + (Math.random()*80));
87 }
88
89 private static int getRandomBalance(){
90 return (int) ((Math.random()*100000)+ (Math.random()*3000) + (Math.random()*500));
91 }
92
93
94 public static TradeDetail generator() {
95 TradeDetail td1 = new TradeDetail();
96 td1.setId(KeyUtil.generatorUUID());
97 Date tradeDate = getRandomDate();
98
99 td1.setSerialno(generateSerialno(tradeDate));
100 td1.setTradeDate(tradeDate);
101 td1.setCreditAmount(new BigDecimal(getRandomCreditAmount()));
102 td1.setDedbitAmount(new BigDecimal(0));
103 td1.setBusinessType("1");
104 td1.setBalance(new BigDecimal(getRandomBalance()));
105
106 Pair account = getRandomAccounts();
107
108 td1.setAccountName((String) account.getObject1());
109 td1.setAccountNo((String) account.getObject2());
110
111
112 Pair oppAccount = getRandomOppAccounts();
113 td1.setOppAccountName((String) oppAccount.getObject1());
114 td1.setOppAccountNo((String) oppAccount.getObject2());
115
116 td1.setDigest(getRandomDigest());
117 td1.setStatus("0");
118 td1.setCreateBy("system");
119 td1.setCreateTime(new Date());
120 td1.setUpdateBy("system");
121 td1.setUpdateTime(new Date());
122 return td1;
123
124 }
125
126 }
9.4，GzipUtil.java（压缩解压类）
1 package bhz.uts.utils;
2
3 import java.io.ByteArrayInputStream;
4 import java.io.ByteArrayOutputStream;
5 import java.io.File;
6 import java.io.FileInputStream;
7 import java.io.FileOutputStream;
8 import java.util.zip.GZIPInputStream;
9 import java.util.zip.GZIPOutputStream;
10
11 public class GzipUtil {
12
13 public static byte[] gzip(byte[] data) throws Exception{
14 ByteArrayOutputStream bos = new ByteArrayOutputStream();
15 GZIPOutputStream gzip = new GZIPOutputStream(bos);
16 gzip.write(data);
17 gzip.finish();
18 gzip.close();
19 byte[] ret = bos.toByteArray();
20 bos.close();
21 return ret;
22 }
23
24 public static byte[] ungzip(byte[] data) throws Exception{
25 ByteArrayInputStream bis = new ByteArrayInputStream(data);
26 GZIPInputStream gzip = new GZIPInputStream(bis);
27 byte[] buf = new byte[1024];
28 int num = -1;
29 ByteArrayOutputStream bos = new ByteArrayOutputStream();
30 while((num = gzip.read(buf, 0 , buf.length)) != -1 ){
31 bos.write(buf, 0, num);
32 }
33 gzip.close();
34 bis.close();
35 byte[] ret = bos.toByteArray();
36 bos.flush();
37 bos.close();
38 return ret;
39 }
40
41 public static void main(String[] args) throws Exception{
42
43 //读取文件
44 String readPath = System.getProperty("user.dir") + File.separatorChar + "sources" + File.separatorChar + "006.jpg";
45 File file = new File(readPath);
46 FileInputStream in = new FileInputStream(file);
47 byte[] data = new byte[in.available()];
48 in.read(data);
49 in.close();
50
51 System.out.println("文件原始大小:" + data.length);
52 //测试压缩
53
54 byte[] ret1 = GzipUtil.gzip(data);
55 System.out.println("压缩之后大小:" + ret1.length);
56
57 byte[] ret2 = GzipUtil.ungzip(ret1);
58 System.out.println("还原之后大小:" + ret2.length);
59
60 //写出文件
61 String writePath = System.getProperty("user.dir") + File.separatorChar + "receive" + File.separatorChar + "006.jpg";
62 FileOutputStream fos = new FileOutputStream(writePath);
63 fos.write(ret2);
64 fos.close();
65
66
67 }
68
69
70
71 }
9.5，KeyUtil.java（主键生成策略类）
1 package bhz.uts.utils;
2
3 import java.util.UUID;
4
5 import com.fasterxml.uuid.EthernetAddress;
6 import com.fasterxml.uuid.Generators;
7 import com.fasterxml.uuid.impl.TimeBasedGenerator;
8
9 /**
10 * <B>系统名称：</B>通用平台<BR>
11 * <B>模块名称：</B>通用平台-公共服务<BR>
12 * <B>中文类名：</B>KeyUtils<BR>
13 * <B>概要说明：</B>主键生成策略-工具类<BR>
14 * @author baihezhuo
15 * @since 2017年2月21日 下午1:55:42
16 */
17 public class KeyUtil {
18
19 /**
20 * <B>方法名称：</B>generatorUUID<BR>
21 * <B>概要说明：</B>主键生成策略<BR>
22 * @author baihezhuo
23 * @since 2017年2月21日 下午2:00:06
24 * @return UUID String
25 */
26 public static String generatorUUID(){
27 TimeBasedGenerator timeBasedGenerator = Generators.timeBasedGenerator(EthernetAddress.fromInterface());
28 return timeBasedGenerator.generate().toString();
29 }
30
31
32
33 }
9.6，Pair.java（键值对类）
1 package bhz.uts.utils;
2
3 public class Pair<T1, T2> {
4 private T1 object1;
5 private T2 object2;
6
7 public Pair(T1 object1, T2 object2) {
8 this.object1 = object1;
9 this.object2 = object2;
10 }
11
12 public T1 getObject1() {
13 return object1;
14 }
15
16 public void setObject1(T1 object1) {
17 this.object1 = object1;
18 }
19
20 public T2 getObject2() {
21 return object2;
22 }
23
24 public void setObject2(T2 object2) {
25 this.object2 = object2;
26 }
27 }
十，主类
10.1，MainConfig.java（主要扫描类）
1 package bhz.uts;
2
3 import org.mybatis.spring.annotation.MapperScan;
4 import org.springframework.context.annotation.ComponentScan;
5 import org.springframework.context.annotation.Configuration;
6
7 @Configuration
8 @MapperScan(basePackages = "bhz.uts.mapper")
9 @ComponentScan(basePackages = {"bhz.uts.*", "bhz.uts.config.*"})
10 public class MainConfig {
11
12 }
10.2，UtsSenderApplication.java（springboot的启动类）
1 package bhz.uts;
2
3 import org.springframework.boot.SpringApplication;
4 import org.springframework.boot.autoconfigure.SpringBootApplication;
5
6 @SpringBootApplication
7 public class UtsSenderApplication {
8
9 public static void main(String[] args) {
10 SpringApplication.run(UtsSenderApplication.class, args);
11 }
12 }
控制台：
1 Java HotSpot(TM) 64-Bit Server VM warning: MaxNewSize (524288k) is equal to or greater than the entire heap (524288k). A new generation size of 524224k will be used.
2
3 . ____ _ __ _ _
4 /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
5 ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
6 \\/ ___)| |_)| | | | | || (_| | ) ) ) )
7 ' |____| .__|_| |_|_| |_\__, | / / / /
8 =========|_|==============|___/=/_/_/_/
9 :: Spring Boot :: (v1.5.6.RELEASE)
10
11 2018-03-21 20:31:27.719 INFO 2180 --- [ main] bhz.uts.UtsSenderApplication : Starting UtsSenderApplication on qingruihappy with PID 2180 (D:\workspace\uts-sender\target\classes started by Administrator in D:\workspace\uts-sender)
12 2018-03-21 20:31:27.731 INFO 2180 --- [ main] bhz.uts.UtsSenderApplication : No active profile set, falling back to default profiles: default
13 2018-03-21 20:31:27.834 INFO 2180 --- [ main] ationConfigEmbeddedWebApplicationContext : Refreshing org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@594001dc: startup date [Wed Mar 21 20:31:27 CST 2018]; root of context hierarchy
14 2018-03-21 20:31:29.885 WARN 2180 --- [ main] o.m.s.mapper.ClassPathMapperScanner : Skipping MapperFactoryBean with name 'tradeDetailMapper' and 'bhz.uts.mapper.TradeDetailMapper' mapperInterface. Bean already defined with the same name!
15 2018-03-21 20:31:29.885 WARN 2180 --- [ main] o.m.s.mapper.ClassPathMapperScanner : No MyBatis mapper was found in '[bhz.uts.mapper]' package. Please check your configuration.
16 2018-03-21 20:31:29.887 WARN 2180 --- [ main] o.s.c.a.ConfigurationClassPostProcessor : Cannot enhance @Configuration bean definition 'mybatisMapperScanerConfig' since its singleton instance has been created too early. The typical cause is a non-static @Bean method with a BeanDefinitionRegistryPostProcessor return type: Consider declaring such methods as 'static'.
17 2018-03-21 20:31:30.295 WARN 2180 --- [ main] figurationPropertiesBindingPostProcessor : Multiple PropertySourcesPlaceholderConfigurer beans registered [propertyConfigure, properdtyConfigure], falling back to Environment
18 2018-03-21 20:31:33.128 INFO 2180 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat initialized with port(s): 8001 (http)
19 2018-03-21 20:31:33.176 INFO 2180 --- [ main] o.apache.catalina.core.StandardService : Starting service [Tomcat]
20 2018-03-21 20:31:33.178 INFO 2180 --- [ main] org.apache.catalina.core.StandardEngine : Starting Servlet Engine: Apache Tomcat/8.5.16
21 2018-03-21 20:31:33.811 INFO 2180 --- [ost-startStop-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring embedded WebApplicationContext
22 2018-03-21 20:31:33.812 INFO 2180 --- [ost-startStop-1] o.s.web.context.ContextLoader : Root WebApplicationContext: initialization completed in 5994 ms
23 2018-03-21 20:31:34.079 INFO 2180 --- [ost-startStop-1] b.u.c.database.DruidDataSourceConfig : druid console manager init : org.springframework.boot.web.servlet.ServletRegistrationBean@13084eb3
24 2018-03-21 20:31:34.143 INFO 2180 --- [ost-startStop-1] b.u.c.database.DruidDataSourceConfig : druid filter register : org.springframework.boot.web.servlet.FilterRegistrationBean@4863d07f
25 2018-03-21 20:31:34.941 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.ServletRegistrationBean : Mapping servlet: 'statViewServlet' to [/druid/*]
26 2018-03-21 20:31:34.943 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.ServletRegistrationBean : Mapping servlet: 'dispatcherServlet' to [/]
27 2018-03-21 20:31:34.948 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'characterEncodingFilter' to: [/*]
28 2018-03-21 20:31:34.949 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'hiddenHttpMethodFilter' to: [/*]
29 2018-03-21 20:31:34.950 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'httpPutFormContentFilter' to: [/*]
30 2018-03-21 20:31:34.950 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'requestContextFilter' to: [/*]
31 2018-03-21 20:31:34.950 INFO 2180 --- [ost-startStop-1] o.s.b.w.servlet.FilterRegistrationBean : Mapping filter: 'webStatFilter' to urls: [/*]
32 2018-03-21 20:31:35.136 ERROR 2180 --- [ main] c.a.druid.pool.DruidAbstractDataSource : maxIdle is deprecated
33 2018-03-21 20:31:35.172 INFO 2180 --- [ main] b.u.c.database.DruidDataSourceConfig : druid datasource config : {
34 CreateTime:"2018-03-21 20:31:35",
35 ActiveCount:0,
36 PoolingCount:0,
37 CreateCount:0,
38 DestroyCount:0,
39 CloseCount:0,
40 ConnectCount:0,
41 Connections:[
42 ]
43 }
44
45 [
46 ]
47 2018-03-21 20:31:36.521 INFO 2180 --- [ main] s.w.s.m.m.a.RequestMappingHandlerAdapter : Looking for @ControllerAdvice: org.springframework.boot.context.embedded.AnnotationConfigEmbeddedWebApplicationContext@594001dc: startup date [Wed Mar 21 20:31:27 CST 2018]; root of context hierarchy
48 2018-03-21 20:31:36.648 INFO 2180 --- [ main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/sender]}" onto public void bhz.uts.service.api.SenderTradeDetailController.sender(java.lang.Integer) throws java.lang.Exception
49 2018-03-21 20:31:36.657 INFO 2180 --- [ main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/error]}" onto public org.springframework.http.ResponseEntity<java.util.Map<java.lang.String, java.lang.Object>> org.springframework.boot.autoconfigure.web.BasicErrorController.error(javax.servlet.http.HttpServletRequest)
50 2018-03-21 20:31:36.658 INFO 2180 --- [ main] s.w.s.m.m.a.RequestMappingHandlerMapping : Mapped "{[/error],produces=[text/html]}" onto public org.springframework.web.servlet.ModelAndView org.springframework.boot.autoconfigure.web.BasicErrorController.errorHtml(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse)
51 2018-03-21 20:31:36.726 INFO 2180 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
52 2018-03-21 20:31:36.727 INFO 2180 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
53 2018-03-21 20:31:36.886 INFO 2180 --- [ main] o.s.w.s.handler.SimpleUrlHandlerMapping : Mapped URL path [/**/favicon.ico] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
54 2018-03-21 20:31:38.052 INFO 2180 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Registering beans for JMX exposure on startup
55 2018-03-21 20:31:38.054 INFO 2180 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Bean with name 'dataSource' has been autodetected for JMX exposure
56 2018-03-21 20:31:38.065 INFO 2180 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Located MBean 'dataSource': registering with JMX server as MBean [com.alibaba.druid.pool:name=dataSource,type=DruidDataSource]
57 spring 加载完毕..
58 远程服务器端已经连接.. 可以进行数据通信....
59 2018-03-21 20:31:40.279 INFO 2180 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 8001 (http)
60 2018-03-21 20:31:40.284 INFO 2180 --- [ main] bhz.uts.UtsSenderApplication : Started UtsSenderApplication in 14.68 seconds (JVM running for 19.764)
61 2018-03-21 20:31:46.045 INFO 2180 --- [nio-8001-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring FrameworkServlet 'dispatcherServlet'
62 2018-03-21 20:31:46.046 INFO 2180 --- [nio-8001-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization started
63 2018-03-21 20:31:46.186 INFO 2180 --- [nio-8001-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization completed in 140 ms
64 2017-06-24 20:14:49
65 2018-03-21 20:31:48.117 INFO 2180 --- [nio-8001-exec-1] com.alibaba.druid.pool.DruidDataSource : {dataSource-1} inited
66 2017-01-14 14:49:26
67 2017-02-05 13:26:04
68 2017-05-22 04:10:30
69 2017-05-22 14:36:46
70 更新同步标志-----------: id: d2119747-2d03-11e8-b721-6c881435c21c
71 更新同步标志-----------: id: d37f09f8-2d03-11e8-b721-6c881435c21c
72 更新同步标志-----------: id: d3c0cde9-2d03-11e8-b721-6c881435c21c
73 更新同步标志-----------: id: d3f3017a-2d03-11e8-b721-6c881435c21c
74 更新同步标志-----------: id: d424239b-2d03-11e8-b721-6c881435c21c
75 2017-03-18 12:42:58
76 更新同步标志-----------: id: d460905c-2d03-11e8-b721-6c881435c21c
77 2017-01-17 16:25:36
78 更新同步标志-----------: id: d48e300d-2d03-11e8-b721-6c881435c21c
79 2017-01-17 23:11:41
80 更新同步标志-----------: id: d4babe4e-2d03-11e8-b721-6c881435c21c
81 2017-07-26 14:46:20
82 更新同步标志-----------: id: d4e8ac1f-2d03-11e8-b721-6c881435c21c
83 2017-06-16 18:03:53
84 更新同步标志-----------: id: d51699f0-2d03-11e8-b721-6c881435c21c
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- <Netty>（二十六）（项目篇）Netty项目之服务端代码（maven+springboot+自定义注解+分库分表+Netty）
- <Netty>（二十一）（高级篇）Netty服务端和客户端创建时序图
- <p>在我们的实际软件项目中，管理团队事实上比写代码或者实现一个客户的需求更为的有挑战性。由于编程实际上是和机器打交道，而和机器打交道，仅仅要你符合机器预定的逻辑，</p>
- <Netty>（二十四）（项目篇）Netty准备之动态代理
- <转>软件项目估算之代码行估算方法
- <独家>DunkingBall的项目代码块知识点细节汇总(杂)
- <Netty>（二十三）（项目篇）Netty准备之数据分库分表的策略
- 【SSH 框架项目的搭建--简化版】使用注解代替xml中的<bean>,减少代码量
- <Netty>（六）（入门篇）noi服务端序列图代码和客户端序列图代码
- <Netty>（入门篇）TIP黏包/拆包问题原因及换行的初步解决之道
- SVN 的使用:用两次就会了,很简单.注意总结【①做完自己代码,首先右键项目>team >“与资源库同步”,把队友的代码更新下来(而不是直接提交),②整合完设置"冲突已解决",才能提交】===
- IOS开发中UI部分UIWebView简单使用<代码演示>
- <四>--RIL层代码分析--整个电话来访过程
- git学习------>从SVN迁移到Git之后，项目开发代码继续在SVN提交，如何同步迁移之后继续在SVN提交的代码到Git？
- <深入理解JavaScript>学习笔记(1)_编写高质量JavaScript代码的基本要点
- <转载> 22种代码味道（Martin Fowler与Kent Beck） http://blog.csdn.net/lovelion/article/details/9301691
- <原创>一串简单的代码牵扯出的session,cookie,$_session,$_cookie之间关系问题
- CxImage的简单使用(编译-->项目设置-->代码示例(PNG透明贴图))
- <<代码整洁之道>>读书笔记二 函数
- <转>RestKit在iOS项目中的使用，包含xcode配置说明