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
new file mode 100644
index 0000000..2d4ada4
--- /dev/null
+++ b/yexuejc-springboot-base/src/test/java/com/yexuejc/springboot/base/test/RedisTest.java
@@ -0,0 +1,108 @@
+package com.yexuejc.springboot.base.test;
+
+import com.yexuejc.base.util.JsonUtil;
+import com.yexuejc.base.util.StrUtil;
+import com.yexuejc.springboot.base.autoconfigure.MutiRedisAutoConfiguration;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+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.SpringRunner;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * redis 操作
+ *
+ * @author maxf
+ * @version 1.0
+ * @ClassName RedisTest
+ * @Description
+ * @date 2018/11/1 11:16
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class RedisTest {
+ /**
+ * 指向redis 0库
+ */
+ @Autowired
+ @Qualifier(MutiRedisAutoConfiguration.BEAN_REDIS_TEMPLATE0)
+ private RedisTemplate redisTemplate0;
+
+ /**
+ * 保存用户登录信息
+ * name:张三
+ */
+ @Test
+ 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() {
+ redisTemplate0.afterPropertiesSet();
+ String name = (String) redisTemplate0.opsForHash().get("login.user.userId1", "name");
+ System.out.println(name);
+ }
+
+ /**
+ * 修改用户登录信息
+ * name:张三->李四
+ * age:20
+ */
+ @Test
+ 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() {
+ 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 aa5b54b..74813f1 100644
--- a/yexuejc-springboot-base/src/test/resources/application.properties
+++ b/yexuejc-springboot-base/src/test/resources/application.properties
@@ -27,4 +27,22 @@ spring.http.encoding.enabled=true
server.tomcat.uri-encoding=UTF-8
#是否开启HTTPS（SSL）请求证书验证忽略：默认false
-yexuejc.enable.ssl-ignore=true
\ No newline at end of file
+yexuejc.enable.ssl-ignore=true
+
+#reids
+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
From ba02c871cccd60a04c30051f16a974e3220e478a Mon Sep 17 00:00:00 2001
From: maxf <1107047387@qq.com>
Date: Thu, 1 Nov 2018 15:25:13 +0800
Subject: [PATCH 12/12] =?UTF-8?q?=E6=95=B4=E7=90=86=E9=9B=86=E6=88=90?=
=?UTF-8?q?=E6=96=87=E6=A1=A3=EF=BC=8C=E6=9C=AA=E5=8F=91=E5=B8=83=E7=89=88?=
=?UTF-8?q?=E6=9C=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
doc/MNS.md | 2 +-
doc/OSS.md | 2 +-
doc/REDIS.md | 4 ++--
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/doc/MNS.md b/doc/MNS.md
index bf92e93..0e22465 100644
--- a/doc/MNS.md
+++ b/doc/MNS.md
@@ -20,7 +20,7 @@ aliyun MNS 消息队列 使用指南