用户：admin/admin liangsonghua/liangsonghua

注册登陆：

拦截器：

@Component

public class PassportInterceptor implements HandlerInterceptor {

@Autowired

private LoginTicketDAO loginTicketDAO;

@Autowired

private UserDAO userDAO;

@Autowired

private HostHolder hostHolder;

@Override

public boolean preHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o) throws Exception {

String ticket = null;

if (httpServletRequest.getCookies() != null) {

for (Cookie cookie : httpServletRequest.getCookies()) {

if (cookie.getName().equals("ticket")) {

ticket = cookie.getValue();

break;

}

}

}

if (ticket != null) {

LoginTicket loginTicket = loginTicketDAO.selectByTicket(ticket);

if (loginTicket == null || loginTicket.getExpired().before(new Date()) || loginTicket.getStatus() != 0) {

return true;

}

User user = userDAO.selectById(loginTicket.getUserId());

hostHolder.setUser(user);

}

return true;

}

@Override

public void postHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, ModelAndView modelAndView) throws Exception {

if (modelAndView != null && hostHolder.getUser() != null) {

modelAndView.addObject("user", hostHolder.getUser());

}

}

@Override

public void afterCompletion(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, Exception e) throws Exception {

hostHolder.clear();

}

}

其中/Model/HostHolder负责管理user信息

访问跳转

@Override

public boolean preHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o) throws Exception {

if (hostHolder.getUser() == null) {

httpServletResponse.sendRedirect("/reglogin?next=" + httpServletRequest.getRequestURI());

}

return true;

}

评论中心部内信

评论表：

统一的评论服务，覆盖所有的实体评论

DROP TABLE IF EXISTS `comment`;

CREATE TABLE `comment` (

`id` INT NOT NULL AUTO_INCREMENT,

`content` TEXT NOT NULL,

`user_id` INT NOT NULL,

`entity_id` INT NOT NULL,

`entity_type` INT NOT NULL,

`created_date` DATETIME NOT NULL,

`status` INT NOT NULL DEFAULT 0,

PRIMARY KEY (`id`),

INDEX `entity_index` (`entity_id` ASC, `entity_type` ASC)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

entity_id可以是questionId/commentId

entity_type可以是question/comment

redis

List(双向列表，适用于最新列表关注列表):lpush/lpop/blpop/lindex/lrange/lrem/linsert/lset/rpush

set(适用于无顺序的集合，点赞点踩抽奖已读共同好友) sdiff/smembers/sinter/scard

SortedSet(排行榜优先队列) zadd/zscore/zrange/zcount/zrank/zrevrank

Hash(对象属性不定长属性数)hset/hget/hgetAll/hexists/hkeys/hvals

KV(单一数据验证码PV缓存)set/setex/incr

关注服务

特点：多对多服务 ID与ID的关联，有序

存储结构：redis:zset/list

Service:通用关注接口

Controller:首页问题关注数，详情问题关注列表，粉丝关注人列表，关注异步事件

队列实现异步

/async/EventProducer.java

public boolean fireEvent(EventModel eventModel) {

try {

String json = JSONObject.toJSONString(eventModel);

String key = RedisKeyUtil.getEventQueueKey();

jedisAdapter.lpush(key, json);

return true;

} catch (Exception e) {

return false;

}

}

/async/EventConsumer.java

Map beans = applicationContext.getBeansOfType(EventHandler.class);

if(beans!=null) {

for(Map.Entry entry:beans.entrySet()) {

List eventTypes = entry.getValue().getSupportEventType();

for(EventType type:eventTypes) {

if(!config.containsKey(type)) {

config.put(type,new ArrayList());

}

config.get(type).add(entry.getValue());

}

}

}

Thread thread = new Thread(new Runnable() {

@Override

public void run() {

while(true) {

String key = RedisKeyUtil.getEventQueueKey();

List events = jedisAdapter.brpop(0, key);

for(String message:events) {

if(message.equals(key)) {

continue;

}

EventModel eventModel = JSON.parseObject(message, EventModel.class);

if(!config.containsKey(eventModel.getType())) {

logger.error("内部错误");

continue;

}

for(EventHandler handler:config.get(eventModel.getType())) {

handler.doHandle(eventModel);

}

}

}

}

});thread.start();

}

在具体的事件中只要 implements EventHandler实现doHandle方法发送站内信即可