【牛客讨论区】第五章：kafka

• 1. 阻塞队列
• 2. Kafka入门
• 3. Spring整合Kafka
• 4. 发送系统通知
• • 4.1 entity
  • 4.2 controller
• 5. 显示系统通知
• • 5.1 通知列表
  • 5.2 通知详情
  • 5.3 未读消息

BlockingQueue

• 解决线程通信的问题。
• 阻塞方法：put、take。

生产者消费者模式

• 生产者：产生数据的线程。
• 消费者：使用数据的线程。

实现类

• ArrayBlockingQueue
• LinkedBlockingQueue
• PriorityBlockingQueue、SynchronousQueue、DelayQueue等

test 目录下新建测试类

package com.nowcoder.community;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

public class BlockingQueueTests {

    public static void main(String[] args) {
        BlockingQueue queue = new ArrayBlockingQueue<>(10);
        new Thread(new Producer(queue)).start();
        new Thread(new Consumer(queue)).start();
        new Thread(new Consumer(queue)).start();
        new Thread(new Consumer(queue)).start();
    }
}
class Producer implements Runnable{

    private BlockingQueue queue;

    public Producer(BlockingQueue queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            for (int i = 0; i < 100; i++) {
                queue.put(i);
                System.out.println(Thread.currentThread().getName() + "生产：" + queue.size());
                Thread.sleep(20);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

class Consumer implements Runnable {

    private BlockingQueue queue;

    public Consumer(BlockingQueue queue) {
        this.queue = queue;
    }

    @Override
    public void run() {
        try {
            while (true) {
                queue.take();
                System.out.println(Thread.currentThread().getName() + "消费了：" + queue.size());
                Thread.sleep(new Random().nextInt(1000));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

运行 main 方法查看结果

Kafka简介

• Kafka是一个分布式的流媒体平台。
• 应用：消息系统、日志收集、用户行为追踪、流式处理。

Kafka特点

• 高吞吐量、消息持久化、高可靠性、高扩展性。

Kafka术语

• Broker、Zookeeper
• Topic、Partition、Offset
• Leader Replica 、Follower Replica

http://kafka.apache.org

小知识：对硬盘的顺序读取，速度是很快的，甚至要快于对内存的随机读取，这也是 kafka 既能持久化又能高性能的原因

【配置】
将素材中的 kafka_2.12-2.2.0.tgz 解压到某个目录即可
配置一下 E:kafka_2.12-2.2.0config 目录下的 zookeeper.properties

dataDir=d:/work/data/zookeeper

配置 server.properties
60行

log.dirs=d:/work/data/kafka-logs

【启动】
打开一个 cmd ，启动 zookeeper

C:Users15642>e:

E:>cd e:/kafka_2.12-2.2.0

e:kafka_2.12-2.2.0>binwindowszookeeper-server-start.bat configzookeeper.properties

再打开一个 cmd，启动 kafka

C:Users15642>e:

E:>cd e:/kafka_2.12-2.2.0

e:kafka_2.12-2.2.0>binwindowskafka-server-start.bat configserver.properties

自动创建了对应的文件夹

再打开一个 cmd
使用 kafka 的生产者，创建主题，发送消息

C:Users15642>e:

E:>cd e:kafka_2.12-2.2.0binwindows

e:kafka_2.12-2.2.0binwindows>kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

e:kafka_2.12-2.2.0binwindows>kafka-topics.bat --list --bootstrap-server localhost:9092
test

e:kafka_2.12-2.2.0binwindows>kafka-console-producer.bat --broker-list localhost:9092 --topic test
>hello
>word

再打开一个 cmd
使用 kafka 的消费者，读取 test 主题下的消息

C:Users15642>e:

E:>cd kafka_2.12-2.2.0binwindows

E:kafka_2.12-2.2.0binwindows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
hello
word

关于Kafka使用的重要提示

现象：在windows的命令行里启动kafka之后，当关闭命令行窗口时，就会强制关闭kafka。这种关闭方式为暴力关闭，很可能会导致kafka无法完成对日志文件的解锁。届时，再次启动kafka的时候，就会提示日志文件被锁，无法成功启动。
方案：将kafka的日志文件全部删除，再次启动即可。
建议：不要暴力关闭kafka，建议通过在命令行执行kafka-server-stop命令来关闭它。
其他：将来在Linux上部署kafka之后，采用后台运行的方式，就会避免这样的问题。

【关闭】
新打开一个 cmd，先关闭 kafka，再关闭 zookeeper

C:Users15642>e:

E:>cd kafka_2.12-2.2.0binwindows

E:kafka_2.12-2.2.0binwindows>kafka-server-stop.bat
删除实例 \DESKTOP-R3O58DJROOTCIMV2:Win32_Process.Handle="16672"
实例删除成功。

E:kafka_2.12-2.2.0binwindows>zookeeper-server-stop.bat
删除实例 \DESKTOP-R3O58DJROOTCIMV2:Win32_Process.Handle="9048"
实例删除成功。
删除实例 \DESKTOP-R3O58DJROOTCIMV2:Win32_Process.Handle="8956"
实例删除成功。
删除实例 \DESKTOP-R3O58DJROOTCIMV2:Win32_Process.Handle="7388"
实例删除成功。

引入依赖

• spring-kafka

配置Kafka

• 配置server、consumer

访问Kafka

• 生产者

kafkaTemplate.send(topic, data); 

• 消费者

@KafkaListener(topics = {"test"}) 
public void handleMessage(ConsumerRecord record) {}

pom.xml

    org.springframework.kafka
    spring-kafka

E:kafka_2.12-2.2.0config 下的 consumer.properties
改一下 group.id

group.id=community-consumer-group

application.properties

# KafkaProperties
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=community-consumer-group
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval=3000

新建测试类

package com.nowcoder.community;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.junit.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@SpringBootTest
public class KafkaTests {

    @Resource
    private KafkaProducer kafkaProducer;

    @Test
    public void testKafka() {
        kafkaProducer.sendMessage("test", "你好");
        kafkaProducer.sendMessage("test", "在吗");

        try {
            Thread.sleep(1000 * 10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

@Component
class KafkaProducer {

    @Resource
    private KafkaTemplate kafkaTemplate;

    public void sendMessage(String topic, String content) {
        kafkaTemplate.send(topic, content);
    }
}

@Component
class KafkaConsumer {

    @KafkaListener(topics = {"test"})
    public void handleMessage(ConsumerRecord record) {
        System.out.println(record.value());
    }
}

先启动 zookeeper，再启动 kafka，最后执行测试方法看看能不能读取到信息

触发事件

• 评论后，发布通知
• 点赞后，发布通知
• 关注后，发布通知

处理事件

• 封装事件对象
• 开发事件的生产者
• 开发事件的消费者

package com.nowcoder.community.entity;

import java.util.HashMap;
import java.util.Map;

public class Event {

    private String topic;
    private int userId;
    private int entityType;
    private int entityId;
    private int entityUserId;
    private Map data = new HashMap<>();

    public String getTopic() {
        return topic;
    }
    //改动所有 set 方法，方便连续调用 set.set.set
    public Event setTopic(String topic) {
        this.topic = topic;
        return this;
    }

    public int getUserId() {
        return userId;
    }

    public Event setUserId(int userId) {
        this.userId = userId;
        return this;
    }

    public int getEntityType() {
        return entityType;
    }

    public Event setEntityType(int entityType) {
        this.entityType = entityType;
        return this;
    }

    public int getEntityId() {
        return entityId;
    }

    public Event setEntityId(int entityId) {
        this.entityId = entityId;
        return this;
    }

    public int getEntityUserId() {
        return entityUserId;
    }

    public Event setEntityUserId(int entityUserId) {
        this.entityUserId = entityUserId;
        return this;
    }

    public Map getData() {
        return data;
    }

    public Event setData(String key, Object value) {
        this.data.put(key, value);
        return this;
    }
}

新建一个包 event，封装生产者和消费者

生产者

package com.nowcoder.community.event;

import com.alibaba.fastjson.JSONObject;
import com.nowcoder.community.entity.Event;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class EventProducer {

    @Resource
    private KafkaTemplate kafkaTemplate;

    // 处理事件
    public void fireEvent(Event event) {
        // 将事件发布到指定的主题
        kafkaTemplate.send(event.getTopic(), JSONObject.toJSONString(event));
    }
}

消费者

CommunityConstant

//主题：评论
String TOPIC_COMMENT = "comment";
//主题：点赞
String TOPIC_LIKE = "like";
//主题：关注
String TOPIC_FOLLOW = "follow";
//系统用户ID
int SYSTEM_USER_ID = 1;

package com.nowcoder.community.event;

import com.alibaba.fastjson.JSONObject;
import com.nowcoder.community.entity.Event;
import com.nowcoder.community.entity.Message;
import com.nowcoder.community.service.MessageService;
import com.nowcoder.community.util.CommunityConstant;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

@Component
public class EventConsumer implements CommunityConstant {

    public static final Logger logger = LoggerFactory.getLogger(EventConsumer.class);

    @Resource
    private MessageService messageService;

    @KafkaListener(topics = {TOPIC_COMMENT, TOPIC_LIKE, TOPIC_FOLLOW})
    public void handleCommentMessage(ConsumerRecord record) {
        if (record == null || record.value() == null) {
            logger.error("消息的内容为空！");
            return;
        }
        Event event = JSONObject.parseObject(record.value().toString(), Event.class);
        if (event == null) {
            logger.error("消息格式错误！");
            return;
        }
        //发送站内通知
        Message message = new Message();
        message.setFromId(SYSTEM_USER_ID);
        message.setToId(event.getEntityUserId());
        message.setConversationId(event.getTopic());
        message.setCreateTime(new Date());

        Map content = new HashMap<>();
        content.put("userId", event.getUserId());
        content.put("entityType", event.getEntityType());
        content.put("entityId", event.getEntityId());

        if (!event.getData().isEmpty()) {
            for (Map.Entry entry : event.getData().entrySet()) {
                content.put(entry.getKey(), entry.getValue());
            }
        }

        message.setContent(JSONObject.toJSONString(content));
        messageService.addMessage(message);
    }

}

CommentMapper 补充方法

Comment selectCommentById(int id);

comment-mapper.xml 实现该方法

    select 
    from comment
    where id = #{id}

 
CommentService 增加方法
 
public Comment findCommentById(int id) {
    return commentMapper.selectCommentById(id);
}
 
CommentController
 
public class CommentController implements CommunityConstant {

	@Resource
	private EventProducer eventProducer;

	@Resource
    private DiscussPostService discussPostService;
 
完善 addComment 方法
 
@PostMapping("/add/{discussPostId}")
public String addComment(@PathVariable("discussPostId") int discussPostId, Comment comment) {
    comment.setUserId(hostHolder.getUser().getId());
    comment.setStatus(0);
    comment.setCreateTime(new Date());
    commentService.addComment(comment);

    //触发评论事件
    Event event = new Event()
            .setTopic(TOPIC_COMMENT)
            .setUserId(hostHolder.getUser().getId())
            .setEntityType(comment.getEntityType())
            .setEntityId(comment.getEntityId())
            .setData("postId", discussPostId);
    if (comment.getEntityType() == ENTITY_TYPE_POST) {
        DiscussPost target = discussPostService.findDiscussPostById(comment.getEntityId());
        event.setEntityUserId(target.getUserId());
    } else if (comment.getEntityType() == ENTITY_TYPE_COMMENT) {
        Comment target = commentService.findCommentById(comment.getEntityId());
        event.setEntityUserId(target.getUserId());
    }
    eventProducer.fireEvent(event);

    return "redirect:/discuss/detail/" + discussPostId;
}
 
LikeController
 
public class LikeController implements CommunityConstant {

	@Resource
	private EventProducer eventProducer;
 
完善 like 方法
 
@PostMapping("/like")
@ResponseBody
public String like(int entityType, int entityId, int entityUserId, int postId) { //加了一个形参postId
    User user = hostHolder.getUser();
    // 点赞
    likeService.like(user.getId(), entityType, entityId, entityUserId);
    // 数量
    long likeCount = likeService.findEntityLikeCount(entityType, entityId);
    // 状态
    int likeStatus = likeService.findEntityLikeStatus(user.getId(), entityType, entityId);
    // 返回的结果
    Map map = new HashMap<>();
    map.put("likeCount", likeCount);
    map.put("likeStatus", likeStatus);

    //触发点赞事件
    if (likeStatus == 1) { //点赞才触发，取消赞就不用了
        Event event = new Event()
                .setTopic(TOPIC_LIKE)
                .setUserId(hostHolder.getUser().getId())
                .setEntityType(entityType)
                .setEntityId(entityId)
                .setEntityUserId(entityUserId)
                .setData("postId", postId);
        eventProducer.fireEvent(event);
    }

    return CommunityUtil.getJSONString(0, null, map);
}
 
FollowController
 
@Resource
private EventProducer eventProducer;
 
完善 follow 方法
 
@PostMapping("/follow")
@ResponseBody
public String follow(int entityType, int entityId) {
    User user = hostHolder.getUser();
    followService.follow(user.getId(), entityType, entityId);

    //触发关注事件
    Event event = new Event()
            .setTopic(TOPIC_FOLLOW)
            .setUserId(user.getId())
            .setEntityType(entityType)
            .setEntityId(entityId)
            .setEntityUserId(entityId);
    eventProducer.fireEvent(event);
    
    return CommunityUtil.getJSONString(0, "已关注！");
}
 
discuss-detail.html
 87行
 

 
139行
 

 
165行
 

 
discuss.js
 
function like(btn, entityType, entityId, entityUserId, postId) {
    $.post(
        CONTEXT_PATH + "/like",
        {"entityType":entityType, "entityId":entityId, "entityUserId":entityUserId, "postId":postId},
        function (data) {
            data = $.parseJSON(data);
            if (data.code == 0) {
                $(btn).children("i").text(data.likeCount);
                $(btn).children("b").text(data.likeStatus==1?'已赞':'赞');
            } else {
                alert(data.msg);
            }
        }
    );
}
 
ServiceLogAspect
 完善 before 方法
 
@Before("pointCut()")
public void before(JoinPoint joinPoint) {
    //日志格式：用户[ip]在[时间点],访问了[com.community.service.xxx()]
    ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
    if (attributes == null) {//增加判空
        return;
    }
    HttpServletRequest request = attributes.getRequest();
    String ip = request.getRemoteHost();
    String now = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
    String target = joinPoint.getSignature().getDeclaringTypeName() + "." + joinPoint.getSignature().getName();
    logger.info(String.format("用户[%s],在[%s],访问了[%s].", ip, now, target));
}
 
启动程序，测试（确保 zookeeper 和 kafka 已经提前启动了），登陆之后随便找个帖子进行回帖，给评论点赞、关注某个人
 
 
去数据库 message 表中查看是否有数据
 
 
5. 显示系统通知 
通知列表
 
显示评论、点赞、关注三种类型的通知
 
通知详情
 
分页显示某一类主题所包含的通知
 
未读消息
 
在页面头部显示所有的未读消息数量
 
5.1 通知列表 
MessageMapper
 增加三个方法
 
//查询某个主题下最新的通知
Message selectLatestNotice(@Param("userId") int userId, @Param("topic") String topic);

//查询某个主题所包含的通知的数量
int selectNoticeCount(@Param("userId") int userId, @Param("topic") String topic);

//查询未读的通知的数量
int selectNoticeUnreadCount(@Param("userId") int userId, @Param("topic") String topic);
 
message-mapper.xml
 实现三个方法
 

    select 
    from message
    where id in (
        select max(id) from message
        where status != 2
        and from_id = 1
        and to_id = #{userId}
        and conversation_id = #{topic}
    )



    select count(id) from message
    where status != 2
        and from_id = 1
        and to_id = #{userId}
        and conversation_id = #{topic}



    select count(id) from message
    where status = 0
        and from_id = 1
        and to_id = #{userId}
        
            and conversation_id = #{topic}
        

public Message findLatestNotice(int userId, String topic) {
    return messageMapper.selectLatestNotice(userId, topic);
}

public int findNoticeCount(int userId, String topic) {
    return messageMapper.selectNoticeCount(userId, topic);
}

public int findNoticeUnreadCount(int userId, String topic) {
    return messageMapper.selectNoticeUnreadCount(userId, topic);
}

public class MessageController implements CommunityConstant {

	@GetMapping("/notice/list")
    public String getNoticeList(Model model) {
        User user = hostHolder.getUser();
        //查询评论类的通知
        Message message = messageService.findLatestNotice(user.getId(), TOPIC_COMMENT);
        Map messageVO = new HashMap<>();
        if (message != null) {
            messageVO.put("message", message);

            String content = HtmlUtils.htmlUnescape(message.getContent());
            HashMap data = JSONObject.parseObject(content, HashMap.class);

            messageVO.put("user", userService.findUserById((Integer) data.get("userId")));
            messageVO.put("entityType", data.get("entityType"));
            messageVO.put("entityId", data.get("entityId"));
            messageVO.put("postId", data.get("postId"));

            int count = messageService.findNoticeCount(user.getId(), TOPIC_COMMENT);
            messageVO.put("count", count);

            int unread = messageService.findNoticeUnreadCount(user.getId(), TOPIC_COMMENT);
            messageVO.put("unread", unread);
        }
        model.addAttribute("commentNotice", messageVO);

        //查询点赞类的通知
        message = messageService.findLatestNotice(user.getId(), TOPIC_LIKE);
        messageVO = new HashMap<>();
        if (message != null) {
            messageVO.put("message", message);

            String content = HtmlUtils.htmlUnescape(message.getContent());
            HashMap data = JSONObject.parseObject(content, HashMap.class);

            messageVO.put("user", userService.findUserById((Integer) data.get("userId")));
            messageVO.put("entityType", data.get("entityType"));
            messageVO.put("entityId", data.get("entityId"));
            messageVO.put("postId", data.get("postId"));

            int count = messageService.findNoticeCount(user.getId(), TOPIC_LIKE);
            messageVO.put("count", count);

            int unread = messageService.findNoticeUnreadCount(user.getId(), TOPIC_LIKE);
            messageVO.put("unread", unread);
        }
        model.addAttribute("likeNotice", messageVO);

        //查询关注类的通知
        message = messageService.findLatestNotice(user.getId(), TOPIC_FOLLOW);
        messageVO = new HashMap<>();
        if (message != null) {
            messageVO.put("message", message);

            String content = HtmlUtils.htmlUnescape(message.getContent());
            HashMap data = JSONObject.parseObject(content, HashMap.class);

            messageVO.put("user", userService.findUserById((Integer) data.get("userId")));
            messageVO.put("entityType", data.get("entityType"));
            messageVO.put("entityId", data.get("entityId"));

            int count = messageService.findNoticeCount(user.getId(), TOPIC_FOLLOW);
            messageVO.put("count", count);

            int unread = messageService.findNoticeUnreadCount(user.getId(), TOPIC_FOLLOW);
            messageVO.put("unread", unread);
        }
        model.addAttribute("followNotice", messageVO);

        //查询未读消息数量
        int letterUnreadCount = messageService.findLetterUnreadCount(user.getId(), null);
        model.addAttribute("letterUnreadCount", letterUnreadCount);
        int noticeUnreadCount = messageService.findNoticeUnreadCount(user.getId(), null);
        model.addAttribute("noticeUnreadCount", noticeUnreadCount);

        return "/site/notice";
    }

int noticeUnreadCount = messageService.findNoticeUnreadCount(user.getId(), null);
model.addAttribute("noticeUnreadCount", noticeUnreadCount);

	系统通知27

notice.html
2行

8-9行

15行

197行

67行 ul 标签

	

		朋友私信
			3
		
	
	

		
			系统通知27
		
	

82行 ul 标签

	
	

		3
		


		

			

				评论
				2019-04-28 14:13:25
			
			

				
					用户
					nowcoder
					评论了你的帖子 ...
				
				

					
共 3 条会话
				
			
		
	
	
	

		3
		


		

			

				赞
				2019-04-28 14:13:25
			
			

				
					用户
					nowcoder
					点赞了你的帖子 ...
				
				

					
共 3 条会话
				
			
		
	
	
	

		3
		


		

			

				关注
				2019-04-28 14:13:25
			
			

				
					用户
					nowcoder
					关注了你 ...
				

					
共 3 条会话
				
			
		
	
					

MessageMapper

//查询某个主题所包含的通知列表
List selectNotices(@Param("userId") int userId,
                            @Param("topic") String topic,
                            @Param("offset") int offset,
                            @Param("limit") int limit);

message-mapper.xml

    select 
    from message
    where status != 2
    and from_id = 1
    and to_id = #{userId}
    and conversation_id = #{topic}
    order by create_time desc
    limit #{offset}, #{limit}

 
MessageService
 
public List findNotices(int userId, String topic, int offset, int limit) {
    return messageMapper.selectNotices(userId, topic, offset, limit);
}
 
MessageController
 
@GetMapping("/notice/detail/{topic}")
public String getNoticeDetail(@PathVariable("topic") String topic, Page page, Model model) {
    User user = hostHolder.getUser();

    page.setLimit(5);
    page.setPath("/notice/detail/" + topic);
    page.setRows(messageService.findNoticeCount(user.getId(), topic));

    List noticeList = messageService.findNotices(user.getId(), topic, page.getOffset(), page.getLimit());
    List> noticeVoList = new ArrayList<>();
    if (noticeList != null) {
        for (Message notice : noticeList) {
            Map map = new HashMap<>();
            //通知
            map.put("notice", notice);
            //内容
            String content = HtmlUtils.htmlUnescape(notice.getContent());
            Map data = JSONObject.parseObject(content, HashMap.class);
            map.put("user", userService.findUserById((Integer) data.get("userId")));
            map.put("entityType", data.get("entityType"));
            map.put("entityId", data.get("entityId"));
            map.put("postId", data.get("postId"));
            //通知的作者
            map.put("fromUser", userService.findUserById(notice.getFromId()));
            noticeVoList.add(map);
        }
    }
    model.addAttribute("notices", noticeVoList);
    //设置已读
    List ids = getLetterIds(noticeList);
    if (!ids.isEmpty()) {
        messageService.readMessage(ids);
    }
    return "/site/notice-detail";
}
 
notice.html
 94行
 

 
116行
 

 
138行
 

 
notice-detail.html
 2行
 

 
8-9行
 


 
15行
 


 
删除 91-150行的 li 标签
 
175-176行
 


 
70行
 
返回
 
在最后面多加一个 script 标签
 

 
76行
 

 
77行
 

 
80行
 
落基山脉下的闲人
 
81行
 
2019-04-25 15:49:32
 
86行 div 标签
 

	
		用户
		nowcoder
		评论了你的帖子,
		点击查看 !
	
	
		用户
		nowcoder
		点赞了你的帖子,
		点击查看 !
	
	
		用户
		nowcoder
		关注了你
		点击查看 !
	

 
110行
 

 
5.3 未读消息 
新建一个拦截器
 
package com.nowcoder.community.controller.interceptor;

import com.nowcoder.community.entity.User;
import com.nowcoder.community.service.MessageService;
import com.nowcoder.community.util.HostHolder;
import org.springframework.stereotype.Component;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@Component
public class MessageInterceptor implements HandlerInterceptor {

    @Resource
    private HostHolder hostHolder;

    @Resource
    private MessageService messageService;

    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
        User user = hostHolder.getUser();
        if (user != null && modelAndView != null) {
            int letterUnreadCount = messageService.findLetterUnreadCount(user.getId(), null);
            int noticeUnreadCount = messageService.findNoticeUnreadCount(user.getId(), null);
            modelAndView.addObject("allUnreadCount", letterUnreadCount + noticeUnreadCount);
        }
    }
}
 
配置它
 WebMvcConfig
 
@Resource
private MessageInterceptor messageInterceptor;

@Override
public void addInterceptors(InterceptorRegistry registry) {
    registry.addInterceptor(loginTicketInterceptor)
            .excludePathPatterns("*.css", "*.js", "*.png", "*.jpg", "*.jpeg");

    registry.addInterceptor(loginRequiredInterceptor)
            .excludePathPatterns("*.css", "*.js", "*.png", "*.jpg", "*.jpeg");

    registry.addInterceptor(messageInterceptor)
            .excludePathPatterns("*.css", "*.js", "*.png", "*.jpg", "*.jpeg");
}
 
index.html
 30行
 
消息12
 
提前开启 zookeeper 和 kafka，启动项目，测试，登录 niuke，给 hahaha 关注，点赞、评论，再登录 hahaha 查看消息
 




转载请注明：文章转载自 www.mshxw.com
本文地址：https://www.mshxw.com/it/1004334.html


   上一篇  Flowable流程审批使用
 
   下一篇  MySQL数据库优化笔记
  






Java相关栏目本月热门文章

  
1【Linux驱动开发】设备树详解（二）设备树语法详解
  
2别跟客户扯细节
  
3Springboot+RabbitMQ+ACK机制(生产方确认(全局、局部)、消费方确认)、知识盲区
  
4【Java】对象处理流（ObjectOutputStream和ObjectInputStream）
  
5【分页】常见两种SpringBoot项目中分页技巧
  
6一文带你搞懂OAuth2.0
  
7我要写整个中文互联网界最牛逼的JVM系列教程 | 「JVM与Java体系架构」章节：虚拟机与Java虚拟机介绍
  
8【Spring Cloud】新闻头条微服务项目：FreeMarker模板引擎实现文章静态页面生成
  
9JavaSE - 封装、static成员和内部类
  
10树莓派mjpg-streamer实现监控及拍照功能调试
  
11用c++写一个蓝屏代码
  
12从JDK8源码中看ArrayList和LinkedList的区别
  
13idea 1、报错java: 找不到符号 符号: 变量 log 2、转换成Maven项目
  
14在openwrt使用C语言增加ubus接口（包含C uci操作）
  
15Spring 解决循环依赖
  
16SpringMVC——基于MVC架构的Spring框架
  
17Andy‘s First Dictionary C++ STL set应用
  
18动态内存管理
  
19我的创作纪念日
  
20Docker自定义镜像-Dockerfile







热门相关搜索



路由器设置
木托盘
宝塔面板
儿童python教程
心情低落
朋友圈
vim
双一流学科
专升本
我的学校
日记学校
西点培训学校
汽修学校
情书
化妆学校
塔沟武校
异形模板
西南大学排名
最精辟人生短句
6步教你追回被骗的钱
南昌大学排名
清朝十二帝
北京印刷学院排名
北方工业大学排名
北京航空航天大学排名
首都经济贸易大学排名
中国传媒大学排名
首都师范大学排名
中国地质大学(北京)排名
北京信息科技大学排名
中央民族大学排名
北京舞蹈学院排名
北京电影学院排名
中国戏曲学院排名
河北政法职业学院排名
河北经贸大学排名
天津中德应用技术大学排名
天津医学高等专科学校排名
天津美术学院排名
天津音乐学院排名
天津工业大学排名
北京工业大学耿丹学院排名
北京警察学院排名
天津科技大学排名
北京邮电大学(宏福校区)排名
北京网络职业学院排名
北京大学医学部排名
河北科技大学排名
河北地质大学排名
河北体育学院排名







学习工具
代数计算器
三角函数
解析几何
立体几何


知识解答
教育知识
百科知识
生活知识
常识知识


写作必备
作文大全
作文素材
句子大全

实用范文


关于我们
关于我们
联系我们
网站地图


 
名师互学网交流群


名师互学网客服





名师互学网 版权所有 (c)2021-2022      ICP备案号：晋ICP备2021003244-6号
 






关于我们
文章归档
网站地图
联系我们
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号：晋ICP备2021003244-6号