12Aug

logstash把mysql数据导入到elasticsearch中 1年前•围观热度 13•笔记 1.下载logstash-8.2.0-windows-x86_642.解压3.在E:\esproject\logstash-8.2.0-windows-x86_64\logstash-8.2.0目录下创建logstash.confinput{#...

12Aug

java 高阶函数 Higher Order Function 1年前•围观热度 23•笔记 一个函数如果输入参数包含函数或返回值是函数，就称为高阶函数。这篇文章介绍高阶函数的一个子集：输入fn，输出fn'。按fn与fn'功能是否一致【即相同输入是否始终对应相同输出】，把这类高阶函数的作用分为两类：包装函数：功能一致修改函数：...

12Aug

presto，spark和impala对比 1年前•围观热度 78•笔记 目标是为测试impalaprestoSparkSql谁的性能更佳，以下结果底层查询的都是普通textfilesnappy压缩后数据，规模为15台机器，若以orcfile、parquet速度能快数倍impala与presto性能相当，SparkSql逊色不...

23Jul

spring cloud通过sidecar支持异构语言微服务 1年前•围观热度 15•笔记 springcloud是java应用世界中微服务的事实标准，它提供了非常丰富且完整的微服务组件，且非常方便与java应用程序进行集成。但是，由于springcloud很多功能是通过javajar包以SDK调用的形式集成到应用程序中的（如eurekacl...

16Jun

Redis中缓存穿透/击穿/雪崩问题和解决方法 1年前•围观热度 15•笔记 缓存问题1.缓存穿透---查不到缓存穿透是指用户想查询一个数据，发现Redis中没有，也就是缓存没有命中，就向持久性数据库发起查询，发现数据库也没有这个数据，于是查询失败了。当用户请求很多的情况下，缓存没有命中，数据库也没有数据，会给数据库造成很大的压力，这...

15Jun

基于Drools规则引擎实现动态接口，将业务逻辑放进数据库 1年前•围观热度 13•笔记 0x0.基于Drools实现动态接口项目已上传至github：后端demo：https://github.com/gx304419380/drools-demo前端：https://github.com/gx304419380/dynamic-drools-w...

08Jun

spring cloud Sleuth分布式服务跟踪介绍和使用及原理解析 1年前•围观热度 162•笔记 1、什么是SpringCloudSleuth？SpringCloudSleuth主要功能就是在分布式系统中提供追踪解决方案。SpringCloudSleuth是对Zipkin的一个封装，对于Span、Trace等信息的生成、接入HTTPRequ...

02Jun

规则引擎可视化drools规则引擎的应用场景 1年前•围观热度 128•笔记 在什么情况下需要使用Drools信用卡申请例如，办信用卡时，年龄、学历、工资、是否有车和房，这些数据都是判断用户是否有申请资格的条件。假设有三条规则，如下所示规则1：无房无车，学历短大以下，月薪低于5000，拒绝申请规则2：)无房无车，学历在大专以下，但月薪...

28May

seata的undo_log表有记录消不掉，控制台不停打印Branch Rollbacked result: PhaseTwo_RollbackFailed_Retryable 1年前•围观热度 201•笔记 使用seata的时候如果undo_log的记录消不掉控制台会不停的打印下面的信息：2022-05-2722:19:37.250[rpcDispatch_RMROLE_1_1_32]INFO...

28May

seata锁表LockKeyConflict锁主键键冲突导致get global lock fail的原因 1年前•围观热度 12•笔记 seata在RM识别锁主键冲突异常时会抛出getgloballockfail异常，代码如下：privatevoidrecognizeLockKeyConflictException(TransactionException&nbs...

28May

Seata AT模式全局事务回滚失败，提示Has dirty records when undo或compare row failed问题以及解决办法 1年前•围观热度 16•笔记 使用seata的过程如果undo_log表一直存留多条记录，大概是seata回滚的时候失败了，一种提示comparerowfailed，可以看一下你update的时候是不是把主键也放到set后面一起更新导致。存在下面问题就是脏数据问题。Hasd...

05May

Drools业务规则管理系统 (BRMS) 介绍及解决方案 1年前•围观热度 18•笔记 Drools是一个业务规则管理系统(BRMS)解决方案。它提供了一个核心业务规则引擎(BRE)、一个Web创作和规则管理应用程序(DroolsWorkbench)、对一致性级别3的决策模型和表示法(DMN)模型的完整运行时支持以及一个用于...

26Apr

开启Ribbon的饥饿加载(eager-load)模式要怎么设置？ 1年前•围观热度 28•笔记 目前测试的时候发现在服务都成功启动的时候第一次访问会有报错的情况发生,但是之后又恢复正常访问通过查询相关文档,了解到要解决此问题那么让需要实例化的类提前创建，而不是在第一次调用的时候创建摘自DD的博客:主要是Ribbon进行客户端负载均衡的Client并不是在...

23Apr

IntelliJ IDEA lombok @Nullable和@NotNull注释的使用 1年前•围观热度 43•笔记 本节介绍在IntelliJIDEA中引入的lombok@Nullable和@NotNull注释，IntelliJIDEA引用这两个注释来通过恒定条件和异常来捕获NullPointerException（NPE）以及@Nullable问题检...

23Apr

Spring RabbitMQ的@RabbitListener注解详细的处理过程 1年前•围观热度 12•笔记 SpringRabbitMQ中消费者可使用@RabbitListener标注的方法进行处理,这里介绍下@RabbitListener注解详细的处理过程。解析类RabbitListenerAnnotationBeanPostProcessor类用于解析Rabb...

22Apr

RabbitMQ整合SpringAMQP Spring Cloud Stream 1年前•围观热度 16•笔记 说明：最底层是消息服务，中间层是绑定层，绑定层和底层的消息服务进行绑定，顶层是消息生产者和消息消费者，顶层可以向绑定层生产消息和和获取消息消费。Barista接口：Barista接口是定义来作为后面类的参数，这一接口定义通道类型和通道名称，通道名称是作为配置用...

21Apr

Springboot允许logger.debug输出日志的设置办法 1年前•围观热度 19•笔记 说实话对日志这东西一直只是太肤浅的懂，就会用logger.info和logger.error输出，今天在写LemonRobot项目的时候，决定把调试信息也打出来，然后根据日志级别控制让上线的时候不显示debug级别的日志。但是运行后发现，默认logger.de...

21Apr

springboot @Slf4j 只显示Error 日志，不显示INFO日志 和DEBUG 日志的解决办法 1年前•围观热度 14•笔记 问题：springboot使用@Slf4j注解的log.debug(),log.info(),log.error(),只显示ERROR日志，不显示DEBUG和INFO日志。原因：application.properties中的loggin...

20Apr

RabbitMQ的confirm模式、return模式，以及消费端的手动确认ACK，以及死信队列的简单使用 1年前•围观热度 14•笔记 前言在消息中间件的实际使用中如何保证消息的可靠性是我们必须要考虑的，因此就需要了解一下Rabbitmq的confirm模式、return模式，以及消费端的手动确认ACK等等了。1、confirm模式：此模式是作用在生产端的，开启了这个模式就可以知道消息有木有发...

20Apr

RabbitMQ重试机制 1年前•围观热度 11•笔记 设计重试数次后，转发到无法处理的队列（后面称之为兜底队列）中，示意图如下：消息-->队列1-->失败-->队列1（数次）-->达到上限-->兜底队列我由于自定义了SimpleRabbitListenerContainerFacto...

20Apr

RabbitMQ进阶——RabbitMQ 发生异常的重试机制 1年前•围观热度 14•笔记 前言消费者在处理消息的过程中可能会发生异常，那么此时此刻该如何处理这个异常的消息呢？RabbitMQ有两个方法channel.basicNack或channel.basicReject能够让消息重新回到原队列中，这样子可以实现重试。但是如果第二次消费又发生...

20Apr

RabbitMQ的事务和重试机制 1年前•围观热度 14•笔记 packageorg.jeecg.boot.starter.rabbitmq.config;importorg.jeecg.boot.starter.rabbitmq.constant.MqConstant;importorg.jeecg.b...

20Apr

RabbitMQ重试机制介绍和实现 1年前•围观热度 31•笔记 1、RabbitMQ重试机制的简介RabbitMQ不会为未确认的消息设置过期时间，它判断此消息是否需要重新投递给消费者的唯一依据是消费该消息连接是否已经断开，这个设置的原因是RabbitMQ允许消费者消费一条消息的时间可以很久很久。RabbitMQ的...

20Apr

RabbitMQ设置手动ack报错：Channel closed； cannot ack/nack 1年前•围观热度 32•笔记 记一次RabbitMQ设置手动ack报错：Channelclosed;cannotack/nack报错内容java.lang.IllegalStateException:Channelclosed;cannot&nbs...

16Apr

RabbitMQ的basicReject / basicNack / basicRecover有哪些区别 1年前•围观热度 25•笔记 channel.basicReject(deliveryTag,true);basic.reject方法拒绝deliveryTag对应的消息，第二个参数是否requeue，true则重新入队列，否则丢弃...

16Apr

RabbitMQ消息确认机制主要有三种模式——重点讲解消费者接收消息手动应答ACK 1年前•围观热度 12•笔记 消息接收的确认机制主要有三种模式：自动确认AcknowledgeMode.NONERabbitMQ成功将消息发出（即将消息成功写入TCPSocket）中立即认为本次投递已经被正确处理，不管消费者端是否成功处理本次投递。所以这种情况如果消费端消费逻辑抛出异常，...

16Apr

RabbitMQ的六种模式：简单模式；主题模式(topic)；订阅与发布模式(fanout)；路由模式(direct)；RPC模式；工作队列 1年前•围观热度 26•笔记 rabbitmq的六种模式：简单模式；主题模式(topic)；订阅与发布模式(fanout)；路由模式(direct)；RPC模式；工作队列。rabbitmq的六种模式rabbitmq的六种模式1、简单模式生产者，一个队列一个或多个消费者，当多个消费者同时监听...

16Apr

RabbitMQ：消息发送确认 与 消息接收确认（ACK） 1年前•围观热度 12•笔记 默认情况下如果一个Message被消费者所正确接收则会被从Queue中移除如果一个Queue没被任何消费者订阅，那么这个Queue中的消息会被Cache（缓存），当有消费者订阅时则会立即发送，当Message被消费者正确接收时，就会被从...

16Apr

RabbitMQ 手动确认模式(项目开发常用模式) 1年前•围观热度 11•笔记 借鉴导言此文借鉴多名CSDN用户博客，并将其博文中关于MQ常用的点，进行了归纳整理借鉴博文来源：[小目标青年][爱吃烤面筋的鱼][dreamboycs][交换机]架构及工作原理MQ架构图名词解释Producer/Consumerproducer&...

16Apr

RabbitMQ消息确认机制——关于消费端手动确认机制实现及原理 1年前•围观热度 13•笔记 前言：上篇文章说了发送端消息确认机制，该篇介绍消费端消息确认机制。消费端确认（在确保每个消息被正确消费的情况，此时才可以将broker删除这个消息）消费端消息机制默认是自动确认的，只要消息接收到，客户端会自动确认，服务端就会移除这个消息，但是该情况下存在问题...

16Apr

Spring AMQP 源码分析 06 - 了解 Spring AMQP 如何手动确认消息 1年前•围观热度 11•笔记 ###准备##目标了解SpringAMQP如何手动确认消息已成功消费##前置知识《SpringAMQP源码分析04-MessageListener》##相关资源Officaldoc：<http://docs.spring.io/...

16Apr

SpringBoot整合RabbitMQ，开启手动应答，失败重传机制 1年前•围观热度 15•笔记 该实例用来测试RabbitMQ发送和接收消息功能并解决以下问题：问题：RabbitMQ默认使用自动应答ack，当消费者宕机，会导致还未被及时处理的消息丢失解决方案：开启手动应答ack和失败重传机制创建项目，导入相关依赖<dependency&...

15Apr

SpringBoot整合RabbitMQ自动模式如何确保消息不丢失？ 1年前•围观热度 19•笔记 rabbitmqbasicReject/basicNack/basicRecover区别channel.basicReject(deliveryTag,true);basic.reject方法拒绝de...

15Apr

SpringBoot整合RabbitMQ的手动应答消息模式（确保消息不丢失） 1年前•围观热度 12•笔记 RabbitMQ之手动应答消息1.为什么需要手动应答当消费者完成一个任务需要一段时间，如果其中一个消费者处理一个长的任务并且只处理了部分突然他挂掉了，会发生什么情况。RabbitMQ一旦向消费者传递了一条消息，便立即将该条消息标记为删除。在这种情况下，突然有个...

14Apr

SpringBoot整合RabbitMq手动确认消息时channel.basicReject()回放队列问题 1年前•围观热度 9•笔记 RabbitMq手动消息确认时：如果用：//第二个参数，true会重新放回队列，所以需要自己根据业务逻辑判断什么时候使用拒绝channel.basicReject(deliveryTag,true);重新放回队列的消息，会放在队列末尾，其Del...

09Apr

解决MySQL Establishing SSL connection without server‘s identity verification is not recommended 1年前•围观热度 14•笔记 最近运行一个项目，在本地地址可以，改为云端数据库连接报错:EstablishingSSLconnectionwithoutserver’sidentityverificationisnotrecommended.AccordingtoM...

06Apr

Spring的AOP切面方法被执行两次的问题及解决办法 1年前•围观热度 16•笔记 Spring的aop相关内容，在学习中我是先使用的配置文件的方式配置切面和切入点。一开始没有任何问题，后来再使用注解的方式配置的时候就出大问题了。如图“开始1”和“结束”字样都是我的切面方法中打印的，“正在添加”是目标方法打印的，也就是说我的切面方法执行了两次...

06Apr

Redis 中的 key 和 value 大小限制以及性能分析 1年前•围观热度 31•笔记 Redis键Rediskey是二进制安全的，这意味着您可以使用任何二进制序列作为key，从“foo”这样的字符串到JPEG文件的内容，空字符串也是有效key。关于key的一些其他规则：很长的key不是一个好主意。例如，1024字节的...

06Apr

控制台出现Loading class `com.mysql.jdbc.Driver'. This is deprecated.要怎么处理 1年前•围观热度 21•笔记 声明：使用JDK9、MYSQL8、idea1.报错信息是这样的;处理：提示信息表明数据库驱动com.mysql.jdbc.Driver'已经被弃用了、应当使用新的驱动com.mysql.cj.jdbc.Driver'所以...

06Apr

Java的元注解之@Documented注解是什么意思？讲述@Documented注解有什么作用？ 1年前•围观热度 16•笔记 @Documented将此注解包含在javadoc中，它代表着此注解会被javadoc工具提取成文档。在doc文档中的内容会因为此注解的信息内容不同而不同。这个注解只是用来标注生成javadoc的时候是否会被记录。用法在自定义注解的时候可以使用@Doc...

01Apr

Spring表达式语言SpEL表达式使用总结 2年前•围观热度 19•笔记 前言SpEL（SpringExpressionLanguage），即Spring表达式语言，是比JSP的EL更强大的一种表达式语言。为什么要总结SpEL，因为它可以在运行时查询和操作数据，尤其是数组列表型数据，因此可以缩减代码量，优化代码结构。个人认为很有...

31Mar

Git创建本地dev分支并关联远程origin/dev分支 2年前•围观热度 18•笔记 创建本地分支gitbranch分支名例如：gitbranchdev，这条命令是基于当前分支创建的本地分支，假设当前分支是master(远程分支)，则是基于master分支创建的本地分支dev。切换到本地分支gitcheckout分支名例如：git...

31Mar

使用springboot 2.0 的时候出现 Redis command timed out的解决办法 2年前•围观热度 31•笔记 环境：springboot2.0.7springdataredisspringboot从1.x升级到2.x后，springdataredis使用的redis客户端驱动从1.x的jedis换到lettuce使用过程中，出现Rediscommand...

31Mar

spring中的SpEL表达式详解 2年前•围观热度 19•笔记 Spring3引入了Spring表达式语言（SpringExpressionLanguage，SpEL），它能够以一种强大和简洁的方式将值装配到bean属性和构造器参数中，在这个过程中所使用的表达式会在运行时计算得到值SpEL拥有很多特性，包括：使用b...

30Mar

JSON日期时间转换时区设置spring.jackson.time-zone=GMT+8 2年前•围观热度 17•笔记 JSON日期时间默认时区和Asia/Shanghai有一个8小时的偏差，转换时区设置spring.jackson.time-zone=GMT+8...

29Mar

SQLTransientConnectionException: HikariPool-1 - Connection is not available, request timed out 2年前•围观热度 16•笔记 网络上大多是修改配置文件。直到看到了这个：http://www.kuazhi.com/post/13561.html不可以直接prepareStatement，需要有一个Connection对象来承接。...

28Mar

spring项目中出现 【will not be managed by Spring】 2年前•围观热度 37•笔记 原因是service没有加@transactional注解未加注解的情况下，出现异常的时候spring将不会回滚事物一般情况下只有对数据有增删改操作才具体加在具体的类方法上...

25Mar

Git问题：You are in 'detached HEAD' state, which means that you're not on any branch问题解决办法 2年前•围观热度 15•笔记 Youarein'detachedHEAD'state,whichmeansthatyou'renotonanybranch问题解决办法1、报错Youarein'de...

24Mar

mybatis http://mybatis.org/dtd/mybatis-3-mapper.dtd 报红解决方案 2年前•围观热度 14•笔记 第一次使用mybatis时,地址可能会变为红色,如图:解决方案:不能简单地忽略，而是要引入资源解决报红问题鼠标悬浮在"http://mybatis.org/dtd/mybatis-3-mapper.dtd"是，点击alt+enter选...

24Mar

IllegalArgumentException: SimpleMessageConverter only supports String, byte[] and Serializ解决办法 2年前•围观热度 20•笔记 IllegalArgumentException:SimpleMessageConverteronlysupportsString,byte[]andSerializ解决办法看看实体类有没有序列化publicclassEn...