map = JsonUtil.json2Obj(msg.getMessageBody(), Map.class);
+ System.out.println(String.format("取出消息：%s", JsonUtil.obj2Json(map)));
+ //操作完成后删除消息
+ }
+}
diff --git a/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/OssTest.java b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/OssTest.java
new file mode 100644
index 0000000..b1250b4
--- /dev/null
+++ b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/OssTest.java
@@ -0,0 +1,74 @@
+package com.yexuejc.springboot.base.test;
+
+import com.aliyun.oss.model.PutObjectResult;
+import com.yexuejc.base.util.ImgUtil;
+import com.yexuejc.base.util.StrUtil;
+import com.yexuejc.springboot.base.autoconfigure.OssFacade;
+import com.yexuejc.springboot.base.exception.ImageException;
+import com.yexuejc.springboot.base.util.LogUtil;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * @author maxf
+ * @version 1.0
+ * @ClassName OssTest
+ * @Description
+ * @date 2018/11/1 14:58
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class OssTest {
+ @Autowired
+ OssFacade ossFacade;
+
+ /**
+ * 上传图片到oss
+ *
+ * 这里是模拟微信登录时，获取到微信头像地址，缓存到base64，然后上传到OSS
+ *
+ */
+ @Test
+ public void put(){
+ putOss4Head(null, "https://avatar.csdn.net/7/8/1/3_wulex.jpg");
+ }
+
+ /**
+ * 上传网络头像至OSS
+ *
+ * @param url 网络图片地址
+ * @return String 本OSS地址
+ */
+ public String putOss4Head(String name, String url) throws ImageException {
+ if (StrUtil.isEmpty(name)) {
+ name = StrUtil.genUUID();
+ }
+ if (name.indexOf(".") == 0) {
+ throw new ImageException("图片名称第一个字符不能为.");
+ }
+ name = "head/" + name;
+ try {
+ LogUtil.bizLogger.info("[第三方登录/注册]上传头像开始：{}", url);
+ InputStream is = ImgUtil.getImageInputStreamFromUrl(url);
+ byte[] b = ImgUtil.getByteArray(is);
+ ImgUtil.ImageInfo imageInfo = ImgUtil.getImageInfoFromInputStream(b);
+ if (name.indexOf(".") < 0) {
+ name = name + "." + imageInfo.getType();
+ }
+ PutObjectResult head = ossFacade.putObject(name, new ByteArrayInputStream(b));
+ } catch (IOException e) {
+ LogUtil.bizLogger.error("[第三方登录/注册]读取网络头像为IO异常:{}", url);
+ e.printStackTrace();
+ throw new ImageException("[第三方登录/注册]读取网络头像为IO异常:" + e.getMessage());
+ }
+ LogUtil.bizLogger.info("[[第三方登录/注册]上传头像结束：{}", url);
+ return name;
+ }
+}
diff --git a/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/RedisTest.java b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/RedisTest.java
index 745cb38..2d4ada4 100644
--- a/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/RedisTest.java
+++ b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/RedisTest.java
@@ -1,7 +1,7 @@
package com.yexuejc.springboot.base.test;
import com.yexuejc.base.util.JsonUtil;
-import com.yexuejc.springboot.base.ApplicationRun;
+import com.yexuejc.base.util.StrUtil;
import com.yexuejc.springboot.base.autoconfigure.MutiRedisAutoConfiguration;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -9,53 +9,100 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.test.context.junit4.SpringRunner;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
-
/**
+ * redis 操作
+ *
* @author maxf
- * @PackageName com.yexuejc.springboot.base.test
+ * @version 1.0
+ * @ClassName RedisTest
* @Description
- * @date 2018/9/26 16:28
+ * @date 2018/11/1 11:16
*/
-@RunWith(SpringJUnit4ClassRunner.class)
-@SpringBootTest(classes = ApplicationRun.class)
+@RunWith(SpringRunner.class)
+@SpringBootTest
public class RedisTest {
+ /**
+ * 指向redis 0库
+ */
@Autowired
@Qualifier(MutiRedisAutoConfiguration.BEAN_REDIS_TEMPLATE0)
- RedisTemplate redisTemplate;
+ private RedisTemplate redisTemplate0;
+ /**
+ * 保存用户登录信息
+ * name:张三
+ */
@Test
- public void insert() {
- Map map = new HashMap<>();
- map.put("a", "b");
- map.put("c", 1);
- map.put("aac", true);
- map.put("q", "asdb");
- redisTemplate.opsForHash().putAll("test.redis", map);
- redisTemplate.expire("test.redis", 10, TimeUnit.MINUTES);
+ public void save() {
+ redisTemplate0.afterPropertiesSet();
+ redisTemplate0.opsForHash().put("login.user.userId1", "name", "张三");
+ redisTemplate0.expire("login.user.userId1", 10, TimeUnit.MINUTES);
}
+ /**
+ * 保存用户登录信息
+ * name:张三
+ * sex:男
+ */
+ @Test
+ public void save2() {
+ redisTemplate0.afterPropertiesSet();
+ Map map = new HashMap<>();
+ map.put("name", "张三");
+ map.put("sex", "男");
+ redisTemplate0.opsForHash().putAll("login.user.userId1", map);
+ redisTemplate0.expire("login.user.userId1", 10, TimeUnit.MINUTES);
+ }
+
+ /**
+ * 保存授权zhangsan的token,过期时间10分钟
+ */
+ @Test
+ public void accessToken() {
+ redisTemplate0.afterPropertiesSet();
+ redisTemplate0.opsForValue().append("zhangsan.access_token", StrUtil.genUUID());
+ redisTemplate0.expire("zhangsan.access_token", 10, TimeUnit.MINUTES);
+ }
+
+
+ /**
+ * 获取用户登录信息
+ * name:张三
+ */
@Test
public void get() {
- Map map = redisTemplate.opsForHash().entries("test.redis");
- System.out.println(JsonUtil.obj2Json(map));
+ redisTemplate0.afterPropertiesSet();
+ String name = (String) redisTemplate0.opsForHash().get("login.user.userId1", "name");
+ System.out.println(name);
}
+ /**
+ * 修改用户登录信息
+ * name:张三->李四
+ * age:20
+ */
@Test
- public void update() {
- Map map = redisTemplate.opsForHash().entries("test.redis");
- redisTemplate.opsForHash().put("test.redis", "q", "123456798");
+ public void put() {
+ redisTemplate0.afterPropertiesSet();
+ redisTemplate0.opsForHash().put("login.user.userId1", "name", "张三");
+ redisTemplate0.opsForHash().put("login.user.userId1", "age", "20");
+ Map map = (Map) redisTemplate0.opsForHash().entries("login.user.userId1");
System.out.println(JsonUtil.obj2Json(map));
}
+ /**
+ * 删除
+ */
@Test
public void del() {
- Boolean delete = redisTemplate.delete("test.redis");
- System.out.println(delete);
+ redisTemplate0.afterPropertiesSet();
+ redisTemplate0.delete("login.user.userId1");
}
+
}
diff --git a/yexuejc-springboot-base/src/test/resources/application.properties b/yexuejc-springboot-base/src/test/resources/application.properties
index 308233e..4d95402 100644
--- a/yexuejc-springboot-base/src/test/resources/application.properties
+++ b/yexuejc-springboot-base/src/test/resources/application.properties
@@ -3,7 +3,8 @@ spring.application.name=@pom.artifactId@
#log
logging.level.root=info
-logging.path=/logs/yexuejc-springboot-base
+logging.path=/logs/yexuejc-springboot-parent
+
yexuejc.http.filter.type=0
@@ -28,8 +29,23 @@ server.tomcat.uri-encoding=UTF-8
#是否开启HTTPS（SSL）请求证书验证忽略：默认false
yexuejc.enable.ssl-ignore=true
+#reids
+#开启指定redis库db0默认开启
yexuejc.redis.db1=true
yexuejc.redis.db2=true
spring.redis.host=121.42.165.89
spring.redis.password=
spring.redis.port=16379
+
+
+#mns
+yexuejc.alibaba.mns.access-key-id=
+yexuejc.alibaba.mns.access-key-secret=
+yexuejc.alibaba.mns.endpoint=http://1734411100610331.mns.cn-hangzhou.aliyuncs.com/
+yexuejc.alibaba.mns.queue-name-prefix=IVT-CONSUMER
+
+#OSS
+yexuejc.alibaba.oss.endpoint=oss-cn-beijing.aliyuncs.com
+yexuejc.alibaba.oss.access-key-secret=
+yexuejc.alibaba.oss.access-key-id=
+yexuejc.alibaba.oss.bucket=guansichou