当前位置： 首页 > news >正文

仿牛客论坛项目day7｜Kafka

news 2026/3/31 12:04:22

一、阻塞队列

创建了一个生产者线程和一个消费者线程。生产者线程向队列中放入元素，消费者线程从队列中取出元素。我们可以看到，当队列为空时，消费者线程会被阻塞，直到生产者线程向队列中放入新的元素。

二、Kafka入门

 发布、订阅

三、spring整合Kafka

首先，需要在项目的pom.xml中添加对Spring Kafka的依赖。然后，可以通过配置类或application.properties来配置Kafka生产者和消费者。接着，使用KafkaTemplate发送消息和使用@KafkaListener注解来监听和接收消息。

四、发送系统通知

功能拆解：

具体实现： 

构造生产者与消费者

生产者：将得到的event发给指定主题

消费者：将event转换为message对象，再将message存入数据库

调用producer

comment controller：生成event，调用生产者的fire event方法。有人点赞时就会将event发出，到消息队列里，消费者监听到后会将event转换为message对象，再将message存入数据库。

like controller：生成event，调用生产者的fire event方法。

follow controller:生成event，调用生产者的fire event方法。

五、显示系统通知

 message表里有新的点赞、评论、关注。现在增加将这些数据显示在系统通知页面的功能。

service：增加查询message通知的方法

controller：将查到的message放入页面

相关文章：

仿牛客论坛项目day7｜Kafka

一、阻塞队列 创建了一个生产者线程和一个消费者线程。生产者线程向队列中放入元素，消费者线程从队列中取出元素。我们可以看到，当队列为空时，消费者线程会被阻塞，直到生产者线程向队列中放入新的元素。 二、Kafka入门 发布、订阅…...

编程日记 2023/8/19 2:49:42

[SpringCloud] 组件性能优化技巧

Feign 配置优化hystrix配置 优化ribbon 优化Servlet 容器 优化Zuul配置 优化 文章目录 1.Servlet 容器 优化2.Feign 配置优化3.Zuul配置 优化4.hystrix配置 优化5.ribbon 优化 1.Servlet 容器 优化 默认情况下, Spring Boot 使用 Tomcat 来作为内嵌的 Servlet 容器, 可以将 We…...

编程日记 2023/8/19 2:48:41

okhttp下载文件 Java下载文件 javaokhttp下载文件 下载文件 java下载 okhttp下载 okhttp

okhttp下载文件 Java下载文件 javaokhttp下载文件 下载文件 java下载 okhttp下载 okhttp 1、引入Maven1.1、okhttp发起请求官网Demo 2、下载文件3、扩充，读写 txt文件内容3.1读写内容 示例 http客户端 用的是 okhttp，也可以用 UrlConnetcion或者apache …...

编程日记 2023/8/19 2:47:39

Oracle/PL/SQL奇技淫巧之Json转表

在Oracle中，有些时候我们需要在一个json文档中查数据 这个时候我们可以通过JSON_TABLE函数来把 json文档 提取成一张可以执行正常查询操作的表 先看JSON_TABLE函数的基础用法： JSON_TABLE(json_data, $.json_path COLUMNS (column_definitions))其中&a…...

编程日记 2023/8/19 2:46:37

每日一学——网络安全

网络安全设计、原则、审计等知识点的精讲如下： 网络安全设计与原则： 网络安全设计是指在系统或网络的设计过程中考虑到安全性，并采取相应的安全措施来保护系统或网络不受威胁。安全设计原则包括最小权限原则（Least Privilege Prin…...

编程日记 2023/8/19 2:45:35

python中的lstm：介绍和基本使用方法

python中的lstm：介绍和基本使用方法 未使用插件 LSTM（Long Short-Term Memory）是一种循环神经网络（RNN）的变体，专门用于处理序列数据。LSTM 可以记忆序列中的长期依赖关系，这使得它非常适合于各…...

编程日记 2023/8/19 2:44:33

【Flink】Flink窗口触发器

数据进入到窗口的时候，窗口是否触发后续的计算由窗口触发器决定，每种类型的窗口都有对应的窗口触发机制。WindowAssigner 默认的 Trigger通常可解决大多数的情况。我们通常使用方式如下,调用trigger()方法把我们想执行触发器传递进去： SingleOutputStreamOperator<Produ…...

编程日记 2023/8/19 2:43:27

深度云化时代，什么样的云网络才是企业的“心头好”？

科技云报道原创。 近年来企业上云的快速推进&#xff0c;对云网络提出了更多需求。 最初&#xff0c;云网络只是满足互联网业务公网接入。 随着移动互联网的发展&#xff0c;企业对云上网络安全隔离能力和互访能力、企业数据中心与云上网络互联、构建混合云的能力&#xff0…...

编程日记 2023/8/19 2:42:25

【快应用】快应用广告学习之激励视频广告

【关键词】 快应用、激励视频广告、广告接入 【介绍】 一、关于激励视频广告 定义&#xff1a;用户通过观看完整的视频广告&#xff0c;获得应用内相关的奖励。适用场景&#xff1a;游戏/快游戏的通关、继续机会、道具获取、积分等场景中&#xff0c;阅读、影音等应用的权益体系…...

编程日记 2023/8/19 2:41:21

国产化系统中遇到的视频花屏、卡顿以及延迟问题的记录与总结

目录 1、国产化系统概述 1.1、国产化操作系统与国产化CPU 1.2、国产化服务器操作系统 1.3、当前国产化系统的主流配置 2、视频解码花屏与卡顿问题 2.1、视频解码花屏 2.2、视频解码卡顿 2.3、关于I帧和P帧的说明 3、国产显卡处理速度慢导致图像卡顿问题 3.1、视频延…...

编程日记 2023/8/19 2:40:18

go内存管理机制

golang内存管理基本是参考tcmalloc来进行的。go内存管理本质上是一个内存池&#xff0c;只不过内部做了很多优化&#xff1a;自动伸缩内存池大小&#xff0c;合理切割内存块。 基本概念&#xff1a; Page&#xff1a;页&#xff0c;一块 8 K大小的内存空间。Go向操作系统申请和…...

编程日记 2023/8/19 2:39:18

【Python】Web学习笔记_flask(5)——会话cookie对象

HTTP是无状态协议&#xff0c;一次请求响应结束后&#xff0c;服务器不会留下对方信息&#xff0c;对于大部分web程序来说&#xff0c;是不方便的&#xff0c;所以有了cookie技术&#xff0c;通过在请求和响应保温中添加cookie数据来保存客户端的状态。 html代码&#xff1a; …...

编程日记 2023/8/19 2:38:16

用友U8+CRM 任意文件上传+读取漏洞复现

0x01 产品简介 用友U8 CRM客户关系管理系统是一款专业的企业级CRM软件&#xff0c;旨在帮助企业高效管理客户关系、提升销售业绩和提供优质的客户服务。 0x02 漏洞概述 用友 U8 CRM客户关系管理系统 getemaildata.php 文件存在任意文件上传和任意文件读取漏洞&#xff0c;攻击…...

编程日记 2023/8/19 2:37:15

【量化课程】08_1.机器学习量化策略基础实战

文章目录 1. 常用机器学习模型1.1 回归模型1.2 分类模型1.2.1 SVC介绍1.2.2 SVC在量化策略中的应用 2. 机器学习量化策略实现的基本步骤3. 策略实现 1. 常用机器学习模型 1.1 回归模型 线性回归多层感知器回归自适应提升树回归随机森林回归 1.2 分类模型 线性分类支持向量机…...

编程日记 2023/8/19 2:36:13

Mongodb 更新集合的方法到底有几种 (中) ？

更新方法 Mongodb 使用以下几种方法来更新文档 &#xff0c; Mongodb V5.0 使用 mongosh 客户端&#xff1a; db.collection.updateOne(<filter>, <update>, <options>) db.collection.updateMany(<filter>, <update>, <options>) db.c…...

编程日记 2023/8/19 2:35:09

预演攻击：谁需要网络靶场，何时需要

"网络演习 "和 "网络靶场 "几乎是当今信息安全领域最流行的词汇。与专业术语不同的是&#xff0c;这些词对于企业和高级管理人员来说早已耳熟能详&#xff1a;法律要求他们进行演习&#xff0c;包括网络演习&#xff0c;而网络射击场也经常在企业界和媒体上…...

编程日记 2023/8/19 2:34:07

【Linux】IO多路转接——poll接口

目录 poll初识 poll函数 poll服务器 poll的优点 poll的缺点 poll初识 poll也是系统提供的一个多路转接接口。 poll系统调用也可以让我们的程序同时监视多个文件描述符上的事件是否就绪&#xff0c;和select的定位是一样的&#xff0c;适用场景也是一样的。 poll函数 po…...

编程日记 2023/8/19 2:33:02

系统架构设计师---OSI七层协议

目录 OSI七层协议 各层主要功能和详细说明 Internet协议的主要协议及其层次关系...

编程日记 2023/8/19 2:32:01

Next.js - Route Groups（路由组）

路由组的作用 在应用程序目录中&#xff0c;嵌套文件夹通常会映射到 URL 路径。不过&#xff0c;您可以将文件夹标记为路由组&#xff0c;以防止该文件夹包含在路由的 URL 路径中。 这样就可以在不影响 URL 路径结构的情况下&#xff0c;将路由段和项目文件组织到逻辑组中。 …...

编程日记 2023/8/19 2:30:58

musl libc ldso 动态加载研究笔记：01

前言 musl 是一个轻量级的标准C库&#xff0c;建立在系统调用之上&#xff0c;可以认为是【用户态】的C 库&#xff0c;与 glibc 或者 uClibc 属于同一类。 基于 musl 的 gcc 工具链包括交叉编译工具链&#xff0c;可以用于编译 Linux 或者其他的操作系统&#xff0c;如当前 L…...

编程日记 2023/8/19 2:29:56

如何用Steam Achievement Manager掌控游戏成就？解锁7大实用技巧

如何用Steam Achievement Manager掌控游戏成就&#xff1f;解锁7大实用技巧 【免费下载链接】SteamAchievementManager A manager for game achievements in Steam. 项目地址: https://gitcode.com/gh_mirrors/st/SteamAchievementManager 在游戏世界中&#xff0c;成就…...

编程新知 2026/3/31 11:45:20

51单片机学习（五）数码管显示

如有大佬发现我文章里的错误&#xff0c;希望多多指出&#xff0c;或者有缺少的也欢迎告诉我&#xff0c;我会尽快补充上去的&#xff0c;感谢各位的支持&#xff0c;要互三的d我哦&#xff01;一.数码管数码管显示屏和U4 74HC245U574H138译码器一位数码管引脚定义一个数码管由…...

编程新知 2026/3/31 11:25:13

Android USB串口通信终极指南：智能家居物联网项目实战

Android USB串口通信终极指南&#xff1a;智能家居物联网项目实战 【免费下载链接】usb-serial-for-android Android USB host serial driver library for CDC, FTDI, Arduino and other devices. 项目地址: https://gitcode.com/gh_mirrors/us/usb-serial-for-android …...

编程新知 2026/3/31 11:15:09

Qwen3.5-2B轻量化技术解析：模型剪枝+KV Cache优化如何降低70%显存占用

Qwen3.5-2B轻量化技术解析&#xff1a;模型剪枝KV Cache优化如何降低70%显存占用 1. 轻量化模型的核心价值 在AI模型部署领域&#xff0c;大模型的资源消耗一直是阻碍其广泛应用的瓶颈。Qwen3.5-2B作为一款仅20亿参数的多模态基础模型&#xff0c;通过创新的轻量化技术实现了…...

编程新知 2026/3/31 10:34:45

FlexRay帧格式拆解：从Header到Trailer，手把手教你读懂汽车总线的‘数据包’

FlexRay帧格式实战解析&#xff1a;像拆解网络包一样掌握汽车总线通信 在汽车电子系统开发中&#xff0c;理解总线协议就像网络工程师需要精通TCP/IP一样重要。FlexRay作为高性能车载网络的核心协议&#xff0c;其帧格式设计既体现了汽车电子对确定性的严苛要求&#xff0c;又融…...

编程新知 2026/3/31 10:16:25

突破B站缓存限制：m4s-converter视频格式转换完全指南

突破B站缓存限制&#xff1a;m4s-converter视频格式转换完全指南 【免费下载链接】m4s-converter 一个跨平台小工具&#xff0c;将bilibili缓存的m4s格式音视频文件合并成mp4 项目地址: https://gitcode.com/gh_mirrors/m4/m4s-converter 当旅行途中想离线观看缓存视频却…...

编程新知 2026/3/31 9:36:08

墨语灵犀助力软件测试：智能测试用例生成与缺陷报告分析

墨语灵犀助力软件测试&#xff1a;智能测试用例生成与缺陷报告分析 作为一名在软件测试领域摸爬滚打多年的工程师&#xff0c;我深知这份工作的“痛”与“乐”。痛的是&#xff0c;面对动辄几十上百页的需求文档&#xff0c;手动编写测试用例的枯燥与耗时&#xff1b;乐的是&a…...

编程新知 2026/3/31 9:07:55

CLIP-GmP-ViT-L-14工具实测：如何用图文匹配优化电商搜索与内容审核

CLIP-GmP-ViT-L-14工具实测&#xff1a;如何用图文匹配优化电商搜索与内容审核 1. 图文匹配技术的商业价值 在数字化商业环境中&#xff0c;图片和文字是两种最核心的内容载体。但长期以来&#xff0c;计算机系统很难真正理解两者之间的语义关联。CLIP-GmP-ViT-L-14模型的出现…...

编程新知 2026/3/31 8:49:49

从HTTP到gRPC：etcd v2与v3 API调用差异及Postman实战解析

1. etcd v2与v3 API的核心差异解析 第一次接触etcd时&#xff0c;你可能和我一样被网上的v2教程坑过——照着文档发送HTTP请求却总是返回404错误。这其实是因为etcd v3默认关闭了v2 API支持&#xff0c;而大多数中文教程还在用陈旧的v2示例。让我们先理清这两个版本的本质区别&…...

编程新知 2026/3/31 8:29:40

像素幻梦效果对比：原生FLUX.1-dev vs 像素幻梦定制版输出质量分析

像素幻梦效果对比&#xff1a;原生FLUX.1-dev vs 像素幻梦定制版输出质量分析 1. 引言 在数字艺术创作领域&#xff0c;像素艺术因其独特的复古美感和现代应用价值而备受关注。Pixel Dream Workshop&#xff08;像素幻梦&#xff09;作为基于FLUX.1-dev模型构建的专业像素艺术…...

编程新知 2026/3/31 8:17:31