Sequarius

Kafka基础概念使用场景作为消息系统（Kafka as a Messaging System） 作为存储系统（Kafka as a Storage System） 流处理（Kafka for Stream Processing） 主题和日志主题是会被推送记录的一个类别或订阅名称 对于每一个主题，Kafka维护了一个分区日志群集! ... Continue reading...

WAL 预写式日志（Write-ahead logging，缩写 WAL）是关系数据库系统中用于提供原子性和持久性（ACID属性中的两个）的一系列技术。在使用WAL的系统中，所有的修... Continue reading...

最近在一次处理上传文件的时候遇到需要guess encode问题，在使用jchardet的过程中使用UniversalDetector调用handleData(buf, 0, read)需要传入一个byte buffer，故大致写了如下一个实现试图从MultipartFile获取InputSteam然后读取buffer。@PostMapping("/upload")public String... Continue reading...

Java9不出意外的又跳票了，传闻Java9加入了JEP 222，所以用OpenJDK体验了一把JShell并分析了下其实现。 JShell简述JShell是一个能够执行Java代码片段、表达式的Shell，从外表看上去像是一个Java的解释器，实际上它是一个Read-Eval-Print Loop，接受命令、代码片段输入，输出运算结果或者一个变更状态。 JShell简易使用指北 通过${J... Continue reading...

前段时间，遇到了一个微信支付调用Rest接口需要SSL授信的问题，遂看了一段时间自SSL证书的集成方式。 Java对安全证书的支持JDK在java.security下有一个KeyStore的工具类，可以通过工厂方法getInstance(String type, String provider)初始化一个密钥存储对象，该对象对主流的密钥格式，如PKCS12、PEM都有了默认支持。 以下是初始... Continue reading...

概述根据数据库结构生成MyBatis可以使用的ORM映射文件的工具有很多，当然最著名的是MyBatis官方的项目MyBatis Generator,该工具提供了一个可定制的ORM生成器，可以自定义生成ORM类型（XML还是基于注解）的方式，可以对表/列进行特殊定制，还可以定义数据库支持,基本主流的数据库都进行支持，项目文档也详细说明了各项配置，下面简单说几个比较常用的配置，其余细节可以参阅文... Continue reading...

使用场景常有一些使用场景，比如操作远程服务失败，需要在指定时间后重试。业务方面，比如有订单在X分钟后没有完成操作则变更状态等需求，这里使用RedisTemplete，利用expired消息实现了一个基于Redis在指时间后进行操作的服务实现。 redis 远程访问redis-cli -h {redis_host} -p {redis_port}配置修改Redis配置文件/etc/redis/... Continue reading...

RxJava 概述A library for composing asynchronous and event-based programs using observable sequences for the Java VM” 一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库。 概念RxJava中观察者模式概念Observable-可观察者，即被观察者 Observer-观察者 subscribe-订阅事件。Observable 和 Observer 通过 subscribe() 。 观察者/订阅者的回调事件onNext(T t)正常的回调事件 onError(Throwable e) 异常发生时的回调事件 onCompleted() 完成时的回调事件 Continue reading...