Skip to content

Commit 64b9692

Browse files
cnzhoutaocnzhoutao
committed
初次提交
1 parent fdbe013 commit 64b9692

File tree

121 files changed

+9104
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

121 files changed

+9104
-0
lines changed

‎cipher-jms-consumer/README.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
# cipher-jms-consumer
2+

‎cipher-jms-consumer/pom.xml

Lines changed: 170 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,170 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4+
<modelVersion>4.0.0</modelVersion>
5+
<parent>
6+
<groupId>org.springframework.boot</groupId>
7+
<artifactId>spring-boot-starter-parent</artifactId>
8+
<version>2.0.4.RELEASE</version>
9+
<relativePath/> <!-- lookup parent from repository -->
10+
</parent>
11+
12+
<groupId>cipher.jms.consumer</groupId>
13+
<artifactId>cipher-jms-consumer</artifactId>
14+
<version>0.0.1-SNAPSHOT</version>
15+
<name>cipher-jms-consumer</name>
16+
<description>Demo project for Spring Boot</description>
17+
18+
<properties>
19+
<java.version>1.8</java.version>
20+
</properties>
21+
22+
<dependencies>
23+
24+
<dependency>
25+
<groupId>org.springframework.boot</groupId>
26+
<artifactId>spring-boot-starter-activemq</artifactId>
27+
</dependency>
28+
<dependency>
29+
<groupId>org.springframework.boot</groupId>
30+
<artifactId>spring-boot-starter-data-redis</artifactId>
31+
</dependency>
32+
33+
<dependency>
34+
<groupId>org.springframework.boot</groupId>
35+
<artifactId>spring-boot-starter-jdbc</artifactId>
36+
</dependency>
37+
38+
39+
<dependency>
40+
<groupId>mysql</groupId>
41+
<artifactId>mysql-connector-java</artifactId>
42+
<scope>runtime</scope>
43+
</dependency>
44+
45+
46+
<dependency>
47+
<groupId>net.sf.json-lib</groupId>
48+
<artifactId>json-lib</artifactId>
49+
<version>2.2.3</version>
50+
<classifier>jdk15</classifier>
51+
</dependency>
52+
53+
54+
<dependency>
55+
<groupId>org.mybatis.spring.boot</groupId>
56+
<artifactId>mybatis-spring-boot-starter</artifactId>
57+
<version>1.3.2</version>
58+
</dependency>
59+
60+
61+
<dependency>
62+
<groupId>org.apache.activemq</groupId>
63+
<artifactId>activemq-pool</artifactId>
64+
</dependency>
65+
66+
67+
<dependency>
68+
<groupId>javax.mail</groupId>
69+
<artifactId>mail</artifactId>
70+
<version>1.4.7</version>
71+
</dependency>
72+
73+
<dependency>
74+
<groupId>com.esotericsoftware.kryo</groupId>
75+
<artifactId>kryo</artifactId>
76+
<version>2.23.0</version>
77+
</dependency>
78+
<dependency>
79+
<groupId>commons-pool</groupId>
80+
<artifactId>commons-pool</artifactId>
81+
<version>1.6</version>
82+
</dependency>
83+
84+
<dependency>
85+
<groupId>org.apache.commons</groupId>
86+
<artifactId>commons-lang3</artifactId>
87+
<version>3.3.2</version>
88+
</dependency>
89+
90+
91+
<dependency>
92+
<groupId>org.springframework.boot</groupId>
93+
<artifactId>spring-boot-starter-web</artifactId>
94+
</dependency>
95+
96+
<dependency>
97+
<groupId>org.springframework.boot</groupId>
98+
<artifactId>spring-boot-starter-test</artifactId>
99+
<scope>test</scope>
100+
</dependency>
101+
102+
<dependency>
103+
<groupId>com.alibaba</groupId>
104+
<artifactId>fastjson</artifactId>
105+
<version>1.2.8</version>
106+
</dependency>
107+
108+
109+
110+
<dependency>
111+
<groupId>com.aliyun</groupId>
112+
<artifactId>aliyun-java-sdk-core</artifactId>
113+
<version>4.0.6</version>
114+
<exclusions>
115+
<exclusion>
116+
<artifactId>httpclient</artifactId>
117+
<groupId>org.apache.httpcomponents</groupId>
118+
</exclusion>
119+
</exclusions> <!-- 注：如提示报错，先升级基础包版，无法解决可联系技术支持 -->
120+
</dependency>
121+
<dependency>
122+
<groupId>com.aliyun</groupId>
123+
<artifactId>aliyun-java-sdk-dysmsapi</artifactId>
124+
<version>1.1.0</version>
125+
</dependency>
126+
127+
<dependency>
128+
<groupId>com.moli</groupId>
129+
<artifactId>dom4j</artifactId>
130+
<version>1.6.1</version>
131+
</dependency>
132+
133+
<dependency>
134+
<groupId>com.moli</groupId>
135+
<artifactId>httpclient</artifactId>
136+
<version>1.0</version>
137+
</dependency>
138+
<dependency>
139+
<groupId>com.moli</groupId>
140+
<artifactId>log4j</artifactId>
141+
<version>1.2.17</version>
142+
</dependency>
143+
144+
145+
<dependency>
146+
<groupId>redis.clients</groupId>
147+
<artifactId>jedis</artifactId>
148+
<version>2.9.0</version>
149+
</dependency>
150+
151+
<dependency>
152+
<groupId>org.apache.commons</groupId>
153+
<artifactId>commons-pool2</artifactId>
154+
<version>2.6.0</version>
155+
</dependency>
156+
157+
158+
</dependencies>
159+
160+
<build>
161+
<finalName>cipher-jms-consumer</finalName>
162+
<plugins>
163+
<plugin>
164+
<groupId>org.springframework.boot</groupId>
165+
<artifactId>spring-boot-maven-plugin</artifactId>
166+
</plugin>
167+
</plugins>
168+
</build>
169+
170+
</project>

‎cipher-jms-consumer/src/main/java/cipher/jms/consumer/CipherJmsConsumerApplication.java

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package cipher.jms.consumer;
2+
3+
import org.mybatis.spring.annotation.MapperScan;
4+
import org.springframework.boot.SpringApplication;
5+
import org.springframework.boot.autoconfigure.SpringBootApplication;
6+
import org.springframework.boot.web.servlet.ServletComponentScan;
7+
8+
@SpringBootApplication
9+
@MapperScan("cipher.jms.consumer.mapper")
10+
@ServletComponentScan
11+
public class CipherJmsConsumerApplication {
12+
13+
public static void main(String[] args) {
14+
SpringApplication.run(CipherJmsConsumerApplication.class, args);
15+
}
16+
17+
}
18+

‎cipher-jms-consumer/src/main/java/cipher/jms/consumer/common/CacheKey.java

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
package cipher.jms.consumer.common;
2+
3+
public class CacheKey {
4+
private static final String CACHE_KEY_KATA_CODE = "KEY_KATACODE_";
5+
6+
public static final String CACHE_KEY_MOBILE_PHONE_SMS_STR = "KEY_MOBILE_PHONE_SMS_STR_";
7+
8+
9+
private static final String CACHE_KEY_RONG_LIAN_INFO = "KEY_RONG_LIAN_INFO";
10+
11+
12+
private static final String CACHE_KEY_ALI_YUN_INFO = "KEY_ALI_YUN_INFO";
13+
14+
15+
private static final String CACHE_KEY_EMAIL_INFO="KEY_EMAIL_INFO";
16+
17+
public static String getCacheKeyEmailInfo() {
18+
return CACHE_KEY_EMAIL_INFO;
19+
}
20+
21+
public static String getyKataCodeCacheKe(String phoneNumberOrMail) {
22+
return CACHE_KEY_KATA_CODE + phoneNumberOrMail;
23+
}
24+
25+
public static String getMobilePhoneSmsStrCacheKey(String phone) {
26+
return CACHE_KEY_MOBILE_PHONE_SMS_STR + phone;
27+
}
28+
29+
public static String getCacheKeyRongLianInfo() {
30+
return CACHE_KEY_RONG_LIAN_INFO;
31+
}
32+
33+
public static String getCacheKeyAliYunInfo() {
34+
return CACHE_KEY_ALI_YUN_INFO;
35+
}
36+
}

‎cipher-jms-consumer/src/main/java/cipher/jms/consumer/common/Constants.java

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
package cipher.jms.consumer.common;
2+
3+
public class Constants {
4+
5+
public final static class WifiStrategyConstant {
6+
public static final String STAFF = "staff";
7+
public static final String VISTOR = "vistor";
8+
}
9+
10+
11+
public static final long CODE_EXPIRE=900;
12+
13+
14+
public static final class responsCode{
15+
public static final int SUCCESS=0;
16+
public static final int FAIL=1;
17+
}
18+
19+
20+
/*默认公司ID为赛赋ID*/
21+
public static final String COMPANYID="123456";
22+
23+
}

‎cipher-jms-consumer/src/main/java/cipher/jms/consumer/config/RedisCacheConfig.java

Lines changed: 92 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,92 @@
1+
package cipher.jms.consumer.config;
2+
3+
import com.fasterxml.jackson.annotation.JsonAutoDetect;
4+
import com.fasterxml.jackson.annotation.PropertyAccessor;
5+
import com.fasterxml.jackson.databind.ObjectMapper;
6+
import org.springframework.beans.factory.annotation.Value;
7+
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
8+
import org.springframework.cache.annotation.CachingConfigurerSupport;
9+
import org.springframework.context.annotation.Bean;
10+
import org.springframework.context.annotation.Configuration;
11+
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
12+
import org.springframework.data.redis.core.RedisTemplate;
13+
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
14+
import org.springframework.data.redis.serializer.StringRedisSerializer;
15+
16+
/**
17+
* @Author: zt
18+
* @Date: 2018/5/24 9:07
19+
*/
20+
@Configuration
21+
@EnableAutoConfiguration
22+
public class RedisCacheConfig extends CachingConfigurerSupport {
23+
24+
@Value("${redis.pool.host}")
25+
private String host;
26+
27+
@Value("${redis.pool.port}")
28+
private int port;
29+
30+
@Value("${redis.pool.timeout}")
31+
private int timeout;
32+
33+
/* @Value("${spring.redis.database}")
34+
private int database;*/
35+
36+
@Value("${redis.pool.password}")
37+
private String password;
38+
39+
public RedisCacheConfig() {
40+
}
41+
42+
/**
43+
* 连接redis的工厂类
44+
* @return
45+
*/
46+
@Bean
47+
public JedisConnectionFactory jedisConnectionFactory() {
48+
JedisConnectionFactory factory = new JedisConnectionFactory();
49+
factory.setHostName(host);
50+
factory.setPort(port);
51+
factory.setTimeout(timeout);
52+
factory.setPassword(password);
53+
// factory.setDatabase(database);
54+
return factory;
55+
}
56+
57+
/**
58+
* 配置RedisTemplate
59+
* 设置添加序列化器
60+
* key 使用string序列化器
61+
* value 使用Json序列化器
62+
* 还有一种简答的设置方式，改变defaultSerializer对象的实现。
63+
* @return
64+
*/
65+
@Bean
66+
public RedisTemplate<String, Object> redisTemplate() {
67+
//StringRedisTemplate的构造方法中默认设置了stringSerializer
68+
RedisTemplate<String, Object> template = new RedisTemplate<>();
69+
//set key serializer
70+
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
71+
template.setKeySerializer(stringRedisSerializer);
72+
template.setHashKeySerializer(stringRedisSerializer);
73+
74+
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
75+
ObjectMapper objectMapper = new ObjectMapper();
76+
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
77+
objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
78+
79+
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
80+
//set value serializer
81+
template.setDefaultSerializer(jackson2JsonRedisSerializer);
82+
83+
template.setConnectionFactory(jedisConnectionFactory());
84+
template.afterPropertiesSet();
85+
return template;
86+
}
87+
88+
89+
90+
91+
92+
}

0 commit comments

Comments
 (0)