Angus博客

原创 MyBatis 流式查询

上面的代码中，1 处我们创建了一个 TransactionTemplate 对象（此处 transactionManager 是怎么来的不用多解释，本文假设读者对 Spring 数据库事务的使用比较熟悉了），2 处执行数据库事务，而数据库事务的内容则是调用 Mapper 对象的流式查询。流式查询的过程当中，数据库连接是保持打开状态的，因此要注意的是：执行一个流式查询后，数据库访问框架就不负责关闭数据库连接了，需要应用在取完数据后自己关闭。所以，解决这个问题的思路不复杂，保持数据库连接打开即可。

原创 Spring Boot集成Quartz实现定时任务的动态创建、启动、暂停、恢复、删除

Quartz

原创 Spring Security 导致 Spring Boot 跨域失效问题

Spring Security，跨域

原创 Java8 CompletableFuture异步非阻塞做法

创建异步任务异步回调handle组合处理CompletableFuture实现了CompletionStage接口和Future接口，前者是对后者的一个扩展，增加了异步回调、流式处理、多个Future组合处理的能力，使Java在处理多任务的协同工作时更加顺畅便利。

原创 Optional使用

如果对象不为空，会执行 Consumer 的动作，否则运行 Runnable。我觉得这个例子就能很好的说明这个问题，只是一个很简单判断，如果用了Optional我们还需要考虑包装值，考虑代码书写，考虑方法调用，虽然只有一行，但是可读性并不好，如果别的程序员去读，我觉得肯定没有if看的明显。or() 与orElse等方法相似，如果对象不为空返回对象，如果为空则返回or()方法中预设的值。方法效果类似，如果对象不为空，则返回对象，如果为空，则返回方法体中的对应参数，所以可以看出这三个方法体中参数是不一样的。

原创 数据库怎么分库分表-原理

系统绝对并发量并没有上来，表的记录并不多，但是字段多，并且热点数据和非热点数据在一起，单行数据所需的存储空间较大，以至于数据库缓存的数据行减少，查询时回去读磁盘数据产生大量随机读 IO，产生 IO 瓶颈。因为各分片节点中的数据可能是随机的，为了排序的准确性，需要将所有节点的前N页数据都排序好做合并，最后再进行整体排序，这样的操作很耗费 CPU 和内存资源，所以页数越大，系统性能就会越差。这是比较常用的方法。MyISAM 使用的是表锁，对表的读写是串行的，所以不用担心并发时两次读取同一个 ID。

原创 SpringBoot 集成Dataway，从此不再需要Controller、Service、DAO、Mapper！

Dataway 是基于 DataQL 服务聚合能力，为应用提供的一个接口配置工具，使得使用者无需开发任何代码就配置一个满足需求的接口。整个接口配置、测试、冒烟、发布，一站式都通过 Dataway 提供的 UI 界面完成。UI 会以 Jar 包方式提供并集成到应用中并和应用共享同一个 http 端口，应用无需单独为 Dataway 开辟新的管理端口。这种内嵌集成方式模式的优点是，可以使得大部分老项目都可以在无侵入的情况下直接应用 Dataway。进而改进老项目的迭代效率，大大减少企业项目研发成本。

原创 SpringBoot 整合Shiro实现动态权限加载更新Session共享单点登录

ADMIN这个号现在没有sys:info:all这个权限的,所以无法访问getInfoAll接口,我们要动态分配权限后,要清掉缓存,在访问接口时候,Shiro会去重新执行授权方法,之后再次把权限和角色数据放入缓存中。Shiro是一个安全框架,项目中主要用它做认证,授权,加密,以及用户的会话管理,虽然Shiro没有SpringSecurity功能更丰富,但是它轻量,简单,在项目中通常业务需求Shiro也都能胜任.再次访问getInfoAll接口,因为缓存中没有数据,Shiro会重新授权查询权限,拦截通过。

转载 springboot + rabbitmq发送邮件实战(保证消息100%投递成功并被消费)

springboot + rabbitmq发送邮件实战

原创 Nacos 2.1.1 正式发布

Nacos 2.1.1

原创 Android 样式系统 | 常见的主题背景属性

Android 样式系统 | 常见的主题背景属性

原创 Android 11 : 隐私和安全

Android11的权限，隐私和安全

原创 Android一分钟配置zxing扫码

一键配置zxing扫码，一分钟搞定

原创 Nginx ssl双向认证包含移动端和PC端证书生成

1：制作CA私钥,在根目录创建一个cert文件夹然后执行openssl genrsa -out ca.key 20482：制作CA公钥/根证书openssl req -new -x509 -days 3650 -key ca.key -out ca.crtCommon Name 填写root；其它可以填”.”3;制作服务器私钥openssl genrsa -out server.pem 1024openssl rsa -in server.pem -out se...

原创 tomcat https双向认证（包含PC端和移动端操作）

原理：个人理解：双向认证就是客户端和服务器之间互相认证，客户端拿着自己的证书和服务器的公钥证书去服务器认证，服务器拿着自己的证书和客服端公钥认证客户端。服务器私钥解密客户端拿服务器公钥加密的数据。客户端拿自己的私钥解密服务器拿客户端公钥加密的数据。操作 ：本地需要有jdk环境和配置1：通过jdktools生成服务器证书创建服务器密钥，其密钥库为 d:/mykeys/server.ks，注意keypass和storepass保持一致，它们分别代表 密钥密码和密钥库密码，注意 CN=lo.

转载 Android RecyclerView嵌套EditView实时更新Item数据

一、场景（例如：购物车）1、当我们需要以列表样式管理某些数据时，可能需要列表项的某个字段可编辑2、编辑Item上的某个字段后可能还要更新相关字段的值二、可能遇到的问题1、列表滑动导致输入框中的数据错位（或者焦点错位）2、无法更新Item上相关的字段项的值3、监听输入框文本更改时陷入死循环三、可行方案（RecyclerView+TextWatcher） 1、用RecyclerView 实现一个ListView的效果：package com.zhn.edit.r...

原创 2021年最新Android中高进阶面试集锦

PDF文档，复制其中一部分由于内容有200多页，，就不截图了，这个是大概的目录，最后附上下载链接点击下载2021年最新Android中高进阶面试集锦.pdf-Android文档类资源-CSDN下载...

原创 JMeter的使用- 结果汇总，用表格查看结果 七

用表格查看结果点击运行会看到运行数据的结果Jmeter提供了很多组件，可以自己尝试点击看看，很多功能提供了很多方面的数据分析和统计

原创 JMeter的使用—集合点与事务 六

一、集合点适用场景：假设在测试系统的最大并发用户数时，如测试10000个并发用户数，我们一般设置线程数为10000，然而JMeter的线程是谁先准备好谁先运行，实际运行的线程数可能达不到10000，可能只有7，8000.此时需要采用集合点的方式来尽量缩短差距。以登录举例，测试10000并发用户数。一般我们都是这样设置的现在开始用添加集合点配置定时器参数模拟用户组的数量：10000超时时间以毫秒为单位：假设为50二、事务事务：就是测试场景中某些步骤组...

原创 JMeter的使用—参数化 五

Jmeter参数化方式有四种，分别是：1）用户自定义变量2）通过CSV Data Set Config实现3）通过添加前置处理器（用户参数）4）通过助手函数参数化一、JMeter参数化——用户自定义变量例：用户需要对上百个接口进行接口测试，但是每个接口需要写请求地址，等信息，就可以自定义一些公共的变量点击添加一个变量然后修改登陆接口 ${url}点击运行效果一样，都可以正常运行，如果觉得数据多，可以点击扫把，清空数据二、JMeter参数化——C...

原创 JMeter的使用—token 四

token令牌，很多场景都需要传递一个令牌参数校验使用，登陆后接口返回一个token，然后根据后端需求，需要在后期的每个接口中加上token参数，为接口增加授权安全的校验，有的写在请求参数中，有的写在请求头中。现在以写在请求参数中为例：通过F12抓取数据，发现，用户详情接口中需要传递token,但是Jmeter中不能写死，需要动态获取登陆后的TokenJmeter中配偶新建一个Http请求然后配置动态获取Token的方式第一种通过Json获取Json数据位...

原创 JMeter的使用—JMeter的断言 三

断言这个东西可以理解为一个拦截器，设置拦截方式，如果匹配就方形，不匹配就报错添加一个响应断言 测试下比如包含code=200就放行，不是就报错，点击运行数据正常直接方形，修改断言规则2000运行报错，并告知错误信息，断言的应用场景很多，比如统一后台接口返回格式，全部接口都是code=200 如果不是就可以直接拦截，需要修改接口，当然也可以设置其它参数，断言还有很多其它的模式设置，自己可以多尝试写几个demo...

原创 JMeter的使用—接口测试 二

点击文件新建一个测试计划测试计划邮件新建一个线程组页面是这样的可以自定义线程组的名字等信息线程属性：线程数：默认1，可以理解为一个用户访问Ramp_up时间秒：代表隔多长时间执行，0代表同时并发 ，默认1秒，不用管循环次数：默认1，即请求次数然后线程组右键新建Http请求名称可以自定义协议 ：http https等根据实际情况填写服务器名称或者IP：填写域名或者IP端口号： 有就填写，没有不写底部三个按钮参...

原创 JMeter的使用—JMeter的安装 一

一、下载JMeter登陆官网下载http://jmeter.apache.org/download_jmeter.cgi下载好后解压到电脑盘符中，不需要安装直接解压就可以使用，我用的5.0，没有下载最新版，但是都是一样的，目录结构：然后打开bin目录，点击ApacheJMeter.jar 或者jmeter.bat都可以运行程序，当然Jmeter运行需要Java环境，在环境变量配置JDK变量，这个自行查询。。。运行后界面如下，默认是英文的，点击Options位...

转载 RabbitMQ 延迟队列，消息延迟推送

作者： 海向出处：RabbitMQ 延迟队列，消息延迟推送 - 海向 - 博客园#应用场景#目前常见的应用软件都有消息的延迟推送的影子，应用也极为广泛，例如：淘宝七天自动确认收货。在我们签收商品后，物流系统会在七天后延时发送一个消息给支付系统，通知支付系统将款打给商家，这个过程持续七天，就是使用了消息中间件的延迟推送功能。 12306 购票支付确认页面。我们在选好票点击确定跳转的页面中往往都会有倒计时，代表着 30 分钟内订单不确认的话将会自动取消订单。其实在下订单那一刻开始购票业务系统就会

原创 MyBatis动态 SQL

动态 SQL 是 MyBatis 的强大特性之一。如果你使用过 JDBC 或其它类似的框架，你应该能理解根据不同条件拼接 SQL 语句有多痛苦，例如拼接时要确保不能忘记添加必要的空格，还要注意去掉列表最后一个列名的逗号。利用动态 SQL，可以彻底摆脱这种痛苦。使用动态 SQL 并非一件易事，但借助可用于任何 SQL 映射语句中的强大的动态 SQL 语言，MyBatis 显著地提升了这一特性的易用性。如果你之前用过 JSTL 或任何基于类 XML 语言的...

原创 EFLK海量日志实时分析检索系统应用实践-16.应用实战收集tomcat日志

打开157节点 tomcat 修改server.xml 文件输出json格式查看日志输出 年月日时分秒修改方法增加注释获取匹配规则：logstash grok配置fileBeat配置fileBeat 先备份老的修改为上述文件描述内容启动fileBeat输出到Kafka后 可以通过Kafka可视化工具 Kafka Eagle 查看可以看到topic有五个点击进去看到 两个 tomcat 之前配置文件...

原创 EFLK海量日志实时分析检索系统应用实践-15.应用实战收集http日志收集

还是在157服务器配置，先关闭nginx服务器，然后配置apache配置内容 json输出日志文件路径启动apache服务然后访问服务器，打印日志：和Nginx类似把之前的Nginx 修改尾http打开配置文件修改启动logstash启动Filebeatlogstash打印日志Kibana创建新的索引然后返回首页查看数据...

原创 EFLK海量日志实时分析检索系统应用实践-14.企业应用中典型的EFLK应用架构解析，应用实战收集nginx日志收集

Nginx日志分析介绍完后，，在157业务服务器配置nginx在http部分配置然后重启nginx，并查看日志访问nginx就会产生日志日志打印了，现在开始配置fileBeat，logstash，kibana157节点的配置详情151节点配置logstash然后启动logstash157启动fileBeat启动后数据就会产生日志接着安装kibana打开kibana可视化页面...

原创 EFLK海量日志实时分析检索系统应用实践-13.elasticsearch启动和head插件

elasticsearch启动“：同理启动其它两个节点，并且查看进程信息发现ElasticSearch 启动用的自己的jdk启动第三个节点的es验证是否启动成功，可以直接访问端口显示集群的名称，版本等等信息80的节点152的节点head插件 一个图形化的插件，这样进行增删改查方便点github的开源插件目录结构修改APP.js 文件地址修改为172.16.213.138：9200，默认是localhost去1

原创 EFLK海量日志实时分析检索系统应用实践-12.elasticsearch架构分析，系统基础调优，安装，配置集群

安装后查看安装路径bin目录的启动文件和config的配置文件编辑配置文件elasticsearch.ymlcluster.name : 集群名称node.name: 接点名称 server1 其它的两个服务器分别是2 和3node.master 是否允许masternode.data.是否允许存储数据path.data 数据存储路径，可以设置多个路径path.logs 日志存储路径bootstrap.m...

原创 EFLK海量日志实时分析检索系统应用实践-11.启动filebeat，分析，输入到kafka，redis和logstash

启动启动日志用157的服务器登陆，输入错误密码。156会产生一条日志日志是json格式 包含了时间元数据错误信息等等登陆Kafka服务器，查看topic 列表 发现创建了 oslogs消费Kafka数据会发现数据很多，而我们只需要message数据处理方式，修改filebeat 配置文件放开processors drop_fields 就是删除指定字段，这样传递给Kafka 的时候 数据就只有自己需要的字段 重启

原创 EFLK海量日志实时分析检索系统应用实践-10.filebeat基础介绍以及运行架构分析

探测器Prospector和收集器Harvester，处理程序Spooler组成 内容可以写入Kafka ，Redis，Logstash等安装后的路径配置文件为filebeat.yml 打开由于内容多，过滤#号后打开类型是log,enable ture 是否启动paths ： 监控log路径fields：增加自定义字段 用来区分filebeat,config.modeles:模块配置name 标识setup.kib...

原创 EFLK海量日志实时分析检索系统应用实践-9.Kafka集群的基本命令，生产和消费数据

显示列表创建topic查看状态生产消息消费消息删除topic

原创 EFLK海量日志实时分析检索系统应用实践-8.zookeeper安装配置

下载解压后目录重命名配置文件，然后修改配置文件server.1 服务的myid 需要配置一个myid 为1 ，同理其它三个服务器分别是2,3启动分别启动三个服务器，，然后启动Kafka。。

原创 EFLK海量日志实时分析检索系统应用实践-7.Kafka分布式集群构建部署过程

bin目录 包含了很多shell脚本config 配置文件 主要掌握 server.peopertieslogs 存储了本身的日志文件，还有消息文件配置文件配置：brokerid 唯一 不能相同listeners 监听器 配置 配置本身服务器ip和吗，默认监听端口默认的消息存储路径，在logs下，，也可以自己修改。。num.partitions = 6 partition配置默认消息保存时间segment 大小 一个G 超过自动创建新文...

原创 EFLK海量日志实时分析检索系统应用实践-6.Kafka 的概念与角色术语

原创 activiti之代码手动驳回（不用网关等操作，直接实现驳回操作）

核心实现类：package com.wsj.service.impl;import cn.hutool.core.util.StrUtil;import com.wsj.enums.ReceivingLinkTypeEnum;import com.wsj.mapper.ProcessMapper;import com.wsj.act.service.ProcessCoreService;import lombok.AllArgsConstructor;import lombok.exte

原创 EFLK海量日志实时分析检索系统应用实践-5.logstash 输出插件 output

输出到文件中设置启动服务控制台输入内容会看到自动创建了一个文件 path=......08.log查看文件内容输出尾压缩文件配置启动服务，输入内容，发现创建了压缩文件解压查看

原创 EFLK海量日志实时分析检索系统应用实践-4.logstash 过滤器插件 Filter

查看 语法的默认定义 IP 都是正则提前定义好的默认通用模式 列表展示的都是模式都是对应的正则改造 ，拆分后message数据相当于存储了两份，，一份拆分后的，一份原生的，，原生就就可以删除remove field删除加入date插件把日志生成的时间timestamp复制到@timestamp查询时间，因为默认的@timestamp 是查询时间并不是日志生成的时间，复制后多余的时间字段就没用了可以删除...