
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
写在前面:各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!前几篇记录完了对枚举类的处理,顺便简单记录一下对布尔值的处理,因为遇到了一个小坑。新增属性:先看下保存相关代码:// 实体属性private Boolean localFlag;// xml中<insert id="savePerson" parameterType="com.exa
写在前面:各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!先大体说一下本篇要完成的事:本地连阿里服务器上的kafka向指定topic发送消息项目中创建一个监听类,接收发送的消息,同时在阿里服务器上创建一个消费者接收消息使用kafkaTemplate提供的addCallback方法监控消息是否发送成功,并进行下一步处理消费topic的指定分区数据发
写在前面:各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!kafka中每个topic可定义多个分区,那么生产者将消息发送到topic时,具体追加到哪个分区呢?上一篇我们已经通过这种方式:@KafkaListener(topics = {"mytopic"},topicPartitions = {@TopicPartition(topic = "m
写在前面:各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!这个通用枚举太简单了,本想不单独整理一篇博客了,闲着也是闲着,整理下吧,废话不多说,先简单说下通用枚举的使用步骤:t_user表中新增字段sex对于枚举类的处理有两种方式:1): implements IEnum<Integer>2): @EnumValue(标记数据库的值)
记录一下关于springcloud alibaba的Nacos、Sentinel相关学习笔记,除了方便自己以后查阅也希望能帮到学习的小伙伴,各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!关于它的介绍及功能请看官网,这里贴一下中文的参考地址:参考网址这一篇开始先记录下Nacos相关的东东,主要记录一下Nacos作为服务注册中心和配置中心两部分,即
今天继续完善一下mybatis系列相关博客,以便查阅,同时也希望能帮助到有需要的小伙伴,各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!上一篇通过指定resultType为map将所有的列映射到HashMap 的键上,虽然在大部分情况下都够用,但是 HashMap 并不是一个很好的领域模型。通常我们使用javabean作为领域模型。MyBatis
写在前面:各位看到此博客的小伙伴,如有不对的地方请及时通过私信我或者评论此博客的方式指出,以免误人子弟。多谢!默认情况下,当项目启动时,监听器就开始工作(监听消费发送到指定 topic 的消息)。如果我们想让监听器在程序运行的过程中能够动态地开启、关闭监听器,可以借助 KafkaListenerEndpointRegistry 实现,只需要定义两个 controller 接口分别通过 KafkaL
本篇记录一下消息的提交方式,默认的消费位移提交的方式是自动提交的,这个由消费者客户端参数enable.auto.commit控制,默认为true,默认的自动提交不是每消费一条消息就提交一次,而是定期的提交,这个定期的周期时间由客户端参数auto.commit.interval.ms配置,默认为5秒,此参数生效的前提是enable.auto.commit参数为true。自动提交消费位移的方式非常简便
静态方法中使用service操作数据库、静态方法中使用mapper操作数据库







