本文共 3763 字，大约阅读时间需要 12 分钟。
用户：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方法发送站内信即可
转载地址：https://blog.csdn.net/weixin_33952775/article/details/114223218 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！
发表评论
最新留言
关于作者
