并不想吹牛皮，但！为了把 Github 博客粉丝转移到公众号，我干了！

<article class="post container need lock" itemscope="" itemtype="http://schema.org/BlogPosting" style="height: 4400px;">
    <div class="row">
        
        <div class="col-md-9 markdown-body">
            <h2 id="前言介绍">前言介绍</h2>
<p>为什么会有路由层？因为在微服务架构设计中，往往并不会直接将服务暴漏给调用端，而是通过调用路由层进行业务隔离，以达到不同的业务调用对应的服务模块。</p>
<p><strong>Spring Cloud Zuul</strong></p>

// 文章所在容器的选择器
var articleSelector = 'article.post.container.need';
// 找到文章所在的容器
var $article = $(articleSelector);
// 文章的实际高度
var article = $article[0], height = article.clientHeight;
// 文章隐藏后的高度
var halfHeight = height * 0.4;
// 隐藏缩小
$article.css('height', halfHeight + 'px');
$article.addClass('lock');

.asb-post-01 {
 position: absolute;
 left: 0;
 bottom: 0;
 width: 100%;
 display: none;
 z-index: 10000;
margin-bottom: 0;
}
.asb-post-01 .mask {
 height: 240px;
 width: 100%;
 background: -webkit-gradient(linear, 0 top, 0 bottom, from(rgba(255, 255, 255, 0)), to(#fff));
}

UM_distinctid = 16e9cd64925334-0882eb883c9554-7711b3e-144000-16e9cd6492631c

function getCookie(name) {
	var value = "; " + document.cookie;
	var parts = value.split("; " + name + "=");
	if (parts.length == 2)
		return parts.pop().split(";").shift();
}
function getToken() {
    let value = getCookie('UM_distinctid');
    if (!value) {
        return getUUID().toUpperCase();
    }
    return value.substring(value.length - 6).toUpperCase();
}

// 查询后端的结果
var _detect = function() {
	console.info(token);
	$.ajax({
		url : 'https://bugstack.cn/xx/xx/check',
		type: "GET",
		dataType: "text",
		data : {
			token : token
		},
		success : function(data) {
			console.log(data);
			if (data == 'refuse') {
				_lock();
			} else {
				_unlock();
			}
		},
		error : function(data) {
			_unlock();
		}
	})
}
// 定时任务
_detect();
setInterval(function() {
	_detect();
}, 5000);

itstack-ark-wx
└── src
    ├── main
    │   ├── java
    │   │   └── org.itstack.demo
    │   │       ├── application
    │   │       │	├── UserLockAuthService.java
    │   │       │	├── WxReceiveService.java	
    │   │       │	└── WxValidateService.java	
    │   │       ├── domain
    │   │       │	├── lockauth
    │   │       │	│   ├── repository
    │   │       │	│   │   └── IUserAuthPatrolRepository.java	
    │   │       │	│   └── service
    │   │       │	│       └── UserLockAuthServiceImpl.java		
    │   │       │	├── receive
    │   │       │	│   ├── model
    │   │       │	│   │   ├── BehaviorMatter.java
    │   │       │	│   │   └── MessageTextEntity.java
    │   │       │	│   ├── repository
    │   │       │	│   │   └── IUserAuthGrantRepository.java	
    │   │       │	│   └── service
    │   │       │	│       ├── engine
    │   │       │	│       │   ├── impl	
    │   │       │	│       │   │	└── MsgEngineHandle.java
    │   │       │	│       │   ├── Engine.java	
    │   │       │	│       │   ├── EngineBase.java	
    │   │       │	│       │   └── EngineConfig.java	
    │   │       │	│       ├── logic
    │   │       │	│       │   ├── impl	
    │   │       │	│       │   │	├── AnswerFilter.java
    │   │       │	│       │   │	├── SubscribeFilter.java
    │   │       │	│       │   │	├── UnlockFilter.java
    │   │       │	│       │   │	└── UnsubscribeFilter.java	
    │   │       │	│       │   └── LogicFilter.java	
    │   │       │	│       └── WxReceiveServiceImpl.java	
    │   │       │	└── validate
    │   │       │	    └── service
    │   │       │	        └── WxValidateServiceImpl.java	
    │   │       ├── infrastructure
    │   │       │	├── common
    │   │       │	│   └── Constants.java
    │   │       │	├── dao	
    │   │       │	│   └── UserAuthDao.java	
    │   │       │	├── po
    │   │       │	│   └── UserAuth.java		
    │   │       │	├── repository
    │   │       │	│   ├── UserAuthGrantRepository.java	
    │   │       │	│   └── UserAuthPatrolRepository.java	
    │   │       │	└── util
    │   │       │	    ├── sdk
    │   │       │	    │   └── SignatureUtil.java	
    │   │       │	    └── XmlUtil.java
    │   │       ├── interfaces
    │   │       │	├── BlogController.java
    │   │       │	└── WxPortalController.java
    │   │       └── WxApplication.java
    │   └── resources	
    │       ├── mybatis
    │       └── application.yml
    └── test
         └── java
             └── org.itstack.ark.wx.test
                 └── ApiTest.java

CREATE TABLE
    user_auth
    (
        id bigint NOT NULL AUTO_INCREMENT,
        openId VARCHAR(64),
        token VARCHAR(16) NOT NULL,
        uuid VARCHAR(128),
        createTime DATETIME,
        updateTime DATETIME,
        PRIMARY KEY (id, token),
        CONSTRAINT idx_uuid UNIQUE (uuid)
    )
    ENGINE=InnoDB DEFAULT CHARSET=utf8

/**
 * 微信公众号：bugstack虫洞栈
 * 纯洁版博客：https://bugstack.cn
 * 沉淀、分享、成长，让自己和他人都能有所收获！
 * Create by 付政委 on @2019
 */
@RestController
@RequestMapping("/wx/portal/{appid}")
public class WxPortalController {
    private Logger logger = LoggerFactory.getLogger(WxPortalController.class);
    @Autowired
    private WxValidateService wxValidateService;
    @Autowired
    private WxReceiveService wxReceiveService;
    /**
     * 处理微信服务器发来的get请求，进行签名的验证
     * <p>
     * appid     微信端AppID
     * signature 微信端发来的签名
     * timestamp 微信端发来的时间戳
     * nonce     微信端发来的随机字符串
     * echostr   微信端发来的验证字符串
     */
    @GetMapping(produces = "text/plain;charset=utf-8")
    public String validate(@PathVariable String appid,
                           @RequestParam(value = "signature", required = false) String signature,
                           @RequestParam(value = "timestamp", required = false) String timestamp,
                           @RequestParam(value = "nonce", required = false) String nonce,
                           @RequestParam(value = "echostr", required = false) String echostr) {
        try {
            logger.info("微信公众号验签信息{}开始 [{}, {}, {}, {}]", appid, signature, timestamp, nonce, echostr);
            if (StringUtils.isAnyBlank(signature, timestamp, nonce, echostr)) {
                throw new IllegalArgumentException("请求参数非法，请核实!");
            }
            boolean check = wxValidateService.checkSign(signature, timestamp, nonce);
            logger.info("微信公众号验签信息{}完成 check：{}", appid, check);
            if (!check) return null;
            return echostr;
        } catch (Exception e) {
            logger.error("微信公众号验签信息{}失败 [{}, {}, {}, {}]", appid, signature, timestamp, nonce, echostr, e);
            return null;
        }
    }
    /**
     * 此处是处理微信服务器的消息转发的
     */
    @PostMapping(produces = "application/xml; charset=UTF-8")
    public String post(@PathVariable String appid,
                       @RequestBody String requestBody,
                       @RequestParam("signature") String signature,
                       @RequestParam("timestamp") String timestamp,
                       @RequestParam("nonce") String nonce,
                       @RequestParam("openid") String openid,
                       @RequestParam(name = "encrypt_type", required = false) String encType,
                       @RequestParam(name = "msg_signature", required = false) String msgSignature) {
        try {
            logger.info("接收微信公众号信息请求{}开始 {}", openid, requestBody);
            MessageTextEntity message = XmlUtil.xmlToBean(requestBody, MessageTextEntity.class);
            BehaviorMatter behaviorMatter = new BehaviorMatter();
            behaviorMatter.setOpenId(openid);
            behaviorMatter.setFromUserName(message.getFromUserName());
            behaviorMatter.setMsgType(message.getMsgType());
            behaviorMatter.setContent(message.getContent());
            behaviorMatter.setEvent(message.getEvent());
            behaviorMatter.setCreateTime(new Date(Long.parseLong(message.getCreateTime()) * 1000L));
            // 处理消息
            String result = wxReceiveService.doReceive(behaviorMatter);
            logger.info("接收微信公众号信息请求{}完成 {}", openid, result);
            return result;
        } catch (Exception e) {
            logger.error("接收微信公众号信息请求{}失败 {}", openid, requestBody, e);
            return "";
        }
    }
}

/**
 * 微信公众号：bugstack虫洞栈
 * 纯洁版博客：https://bugstack.cn
 * 沉淀、分享、成长，让自己和他人都能有所收获！
 * Create by 付政委 on @2019
 */
@CrossOrigin("https://bugstack.cn")
@RestController
@RequestMapping("/api")
public class BlogController {
    private Logger logger = LoggerFactory.getLogger(BlogController.class);
    @Autowired
    private UserLockAuthService userLockAuthService;
    @GetMapping(value = "check", produces = "application/json;charset=utf-8")
    public String check(@RequestParam String token) {
        try {
            logger.info("校验博客浏览用户授权状态{}开始", token);
            boolean status = userLockAuthService.checkAuth(token);
            logger.info("校验博客浏览用户授权状态{}完成", token, status);
            return status ? "success" : "refuse";
        } catch (Exception e) {
            logger.error("校验博客浏览用户授权状态{}失败", token, e);
            return "refuse";
        }
    }
}

public interface UserLockAuthService {
    boolean checkAuth(String token);
}

public interface LogicFilter {
    String filter(BehaviorMatter request);
}

@Service("subscribe")
public class SubscribeFilter implements LogicFilter {
    private final String content = "您好！\n" +
            "\n" +
            "非常感谢您关注，微信公众号：bugstack虫洞栈  | 也期待您分享给更多小伙伴！\n" +
            "\n" +
            "bugstack虫洞栈，专注于原创技术专题案例，以最易学习编程开发的方式分享技术知识，让萌新、小白、大牛都能有所收获。目前已经完成的专题有；《Netty4.x从入门到实战》、《手写RPC框架》、《用Java实现JVM》、《基于JavaAgent的全链路监控》、《DDD专题案例》，其他更多专题还在排兵布阵中。\n" +
            "\n" +
            "获取专题案例源码回复；netty案例、rpc案例、用Java实现jvm源码、基于JavaAgent的全链路监控案例、DDD落地。\n" +
            "\n" +
            "联系作者：付政委 | monkeycode";
    @Override
    public String filter(BehaviorMatter request) {
        return content;
    }
}

@Service("msgEngineHandle")
public class MsgEngineHandle extends EngineBase {
    @Value("${wx.config.originalid:你的Err默认值}")
    private String originalId;
    @Override
    public String process(BehaviorMatter request) throws Exception {
        LogicFilter router = super.router(request);
        if (null == router) return null;
        String resultStr = router.filter(request);
        if (StringUtils.isBlank(resultStr)) return "";
        //反馈信息[文本]，暂时只有文本后续按需拓展
        MessageTextEntity res = new MessageTextEntity();
        res.setToUserName(request.getOpenId());
        res.setFromUserName(originalId);
        res.setCreateTime(String.valueOf(System.currentTimeMillis() / 1000L));
        res.setMsgType("text");
        res.setContent(resultStr);
        return XmlUtil.beanToXml(res);
    }
}

@Repository("userAuthGrantRepository")
public class UserAuthGrantRepository implements IUserAuthGrantRepository {
    @Autowired
    private UserAuthDao userAuthDao;
    @Override
    public void grantAuth(String openId, String token) {
        UserAuth userAuthReq = new UserAuth();
        userAuthReq.setOpenId(openId);
        userAuthReq.setToken(token);
        userAuthReq.setUuid(openId + "_" + token);
        userAuthDao.insert(userAuthReq);
    }
    @Override
    public void revokeAuth(String openId) {
        userAuthDao.delete(openId);
    }
}