foreach 的主要用在构建in条件中，它可以在SQL语句中进行迭代一个集合。foreach 元素的属性主要有 item，index，collection，open，separator，close。item 表示集合中每一个元素进行迭代时的别名，index 指 定一个名字，用于表示在迭代过程中，每次迭代到的位置，open 表示该语句以什么开始，separator 表示在每次进行迭代之间以什么符号作为分隔 符，close 表示以什么结束。在使用 foreach 的时候最关键的也是最容易出错的就是 collection 属性，该属性是必须指定的，但是在不同情况 下，该属性的值是不一样的，主要有一下3种情况：如果传入的是单参数且参数类型是一个List的时候，collection 属性值为 list如果传入的是单参数且参数类型是一个 array 数组的时候，collection 的属性值为 array如果传入的参数是多个的时候，我们就需要把它们封装成一个 Map 了，当然单参数也可以封装成map，实际上如果你在传入参数的时候，在 breast 里面也是会把它封装成一个 Map 的，map 的 key 就是参数名，所以这个时候 collection 属性值就是传入的 List 或 array 对象在自己封装的 map 里面的 key 。下面分别来看看上述三种情况的示例代码：1.单参数 Li ...继续阅读 (21)

1. 前言单例(Singleton)应该是开发者们最熟悉的设计模式了，并且好像也是最容易实现的——基本上每个开发者都能够随手写出——但是，真的是这样吗？作为一个Java开发者，也许你觉得自己对单例模式的了解已经足够多了。我并不想危言耸听说一定还有你不知道的——毕竟我自己的了解也的确有限，但究竟你自己了解的程度到底怎样呢？往下看，我们一起来聊聊看~2. 什么是单例？单例对象的类必须保证只有一个实例存在——这是维基百科上对单例的定义，这也可以作为对意图实现单例模式的代码进行检验的标准。对单例的实现可以分为两大类——懒汉式和饿汉式，他们的区别在于：懒汉式：指全局的单例实例在第一次被使用时构建。饿汉式：指全局的单例实例在类装载时构建。从它们的区别也能看出来，日常我们使用的较多的应该是懒汉式的单例，毕竟按需加载才能做到资源的最大化利用嘛~3. 懒汉式单例先来看一下懒汉式单例的实现方式。3.1 简单版本看最简单的写法Version 1：// Version 1 public class Single1 { private static Single1 instance; public static Single1 getInstance() { if (instance == null) { instance = new Single1( ...继续阅读 (21)

doCreateBean方法上文Spring源码分析：非懒加载的单例Bean初始化过程（上），分析了单例的Bean初始化流程，并跟踪代码进入了主流程，看到了Bean是如何被实例化出来的。先贴一下AbstractAutowireCapableBeanFactory的doCreateBean方法代码：protected Object doCreateBean(final String beanName, final RootBeanDefinition mbd, final Object[] args) { // Instantiate the bean. BeanWrapper instanceWrapper = null; if (mbd.isSingleton()) { instanceWrapper = this.factoryBeanInstanceCache.remove(beanName); } if (instanceWrapper == null) { instanceWrapper = createBeanInstance(beanName, mbd, args); } final Object bean = (instanceWrapper != null ? instance ...继续阅读 (25)

代码入口上文【Spring源码分析】Bean加载流程概览，比较详细地分析了Spring上下文加载的代码入口，并且在AbstractApplicationContext的refresh方法中，点出了finishBeanFactoryInitialization方法完成了对于所有非懒加载的Bean的初始化。finishBeanFactoryInitialization方法中调用了DefaultListableBeanFactory的preInstantiateSingletons方法，本文针对preInstantiateSingletons进行分析，解读一下Spring是如何初始化Bean实例对象出来的。DefaultListableBeanFactory的preInstantiateSingletons方法DefaultListableBeanFactory的preInstantiateSingletons方法，顾名思义，初始化所有的单例Bean，看一下方法的定义：public void preInstantiateSingletons() throws BeansException { if (this.logger.isInfoEnabled()) { this.logger.info("Pre-instantiating singletons in " ...继续阅读 (28)

代码入口之前写文章都会啰啰嗦嗦一大堆再开始，进入【Spring源码分析】这个板块就直接切入正题了。很多朋友可能想看Spring源码，但是不知道应当如何入手去看，这个可以理解：Java开发者通常从事的都是Java Web的工作，对于程序员来说，一个Web项目用到Spring，只是配置一下配置文件而已，Spring的加载过程相对是不太透明的，不太好去找加载的代码入口。下面有很简单的一段代码可以作为Spring代码加载的入口：ApplicationContext ac = new ClassPathXmlApplicationContext("spring.xml"); ac.getBean(XXX.class);ClassPathXmlApplicationContext用于加载CLASSPATH下的Spring配置文件，可以看到，第二行就已经可以获取到Bean的实例了，那么必然第一行就已经完成了对所有Bean实例的加载，因此可以通过ClassPathXmlApplicationContext作为入口。为了后面便于代码阅读，先给出一下ClassPathXmlApplicationContext这个类的继承关系：大致的继承关系是如上图所示的，由于版面的关系，没有继续画下去了，左下角的ApplicationContext应当还有一层继承关系，比较关键的一点是它是BeanFactory的子接 ...继续阅读 (21)

已经对Stream API的用法鼓吹够多了，用起简洁直观，但性能到底怎么样呢？会不会有很高的性能损失？本节我们对Stream API的性能一探究竟。为保证测试结果真实可信，我们将JVM运行在-server模式下，测试数据在GB量级，测试机器采用常见的商用服务器，配置如下：OSCentOS 6.7 x86_64CPUIntel Xeon X5675, 12M Cache 3.06 GHz, 6 Cores 12 Threads内存96GBJDKjava version 1.8.0_91, Java HotSpot(TM) 64-Bit Server VM测试所用代码在这里，测试结果汇总.测试方法和测试数据性能测试并不是容易的事，Java性能测试更费劲，因为虚拟机对性能的影响很大，JVM对性能的影响有两方面：GC的影响。GC的行为是Java中很不好控制的一块，为增加确定性，我们手动指定使用CMS收集器，并使用10GB固定大小的堆内存。集体到JVM参数就是-XX:+UseConcMarkSweepGC -Xms10G -Xmx10GJIT(Just-In-Time)即时编译技术。即时编译技术会将热点代码在JVM运行的过程中编译成本地代码，测试时我们会先对程序预热，触发对测试函数的即时编译。相关的JVM参数是-XX:CompileThreshold=10000。Stream并行执行时用到F ...继续阅读 (25)

前面我们已经学会如何使用Stream API，用起来真的很爽，但简洁的方法下面似乎隐藏着无尽的秘密，如此强大的API是如何实现的呢？Pipeline是怎么执行的，每次方法调用都会导致一次迭代吗？自动并行又是怎么做到的，线程个数是多少？本节我们学习Stream流水线的原理，这是Stream实现的关键所在。首先回顾一下容器执行Lambda表达式的方式，以ArrayList.forEach()方法为例，具体代码如下：// ArrayList.forEach() public void forEach(Consumersuper Eaction) { ... for (int i=0; modCount == expectedModCount && i < size; i++) { action.accept(elementData[i]);// 回调方法 } ... }我们看到ArrayList.forEach()方法的主要逻辑就是一个for循环，在该for循环里不断调用action.accept()回调方法完成对元素的遍历。这完全没有什么新奇之处，回调方法在Java GUI的监听器中广泛使用。Lambda表达式的作用就是相当于一个回调方法，这很好理解。Stream API中大量使用Lambda表达式作为回调方法，但这并不是关键。理解Str ...继续阅读 (26)

上一节介绍了部分Stream常见接口方法，理解起来并不困难，但Stream的用法不止于此，本节我们将仍然以Stream为例，介绍流的规约操作。规约操作（reduction operation）又被称作折叠操作（fold），是通过某个连接动作将所有元素汇总成一个汇总结果的过程。元素求和、求最大值或最小值、求出元素总个数、将所有元素转换成一个列表或集合，都属于规约操作。Stream类库有两个通用的规约操作reduce()和collect()，也有一些为简化书写而设计的专用规约操作，比如sum()、max()、min()、count()等。最大或最小值这类规约操作很好理解（至少方法语义上是这样），我们着重介绍reduce()和collect()，这是比较有魔法的地方。多面手reduce()reduce操作可以实现从一组元素中生成一个值，sum()、max()、min()、count()等都是reduce操作，将他们单独设为函数只是因为常用。reduce()的方法定义有三种重写形式：Optionalreduce(BinaryOperatoraccumulator)T reduce(T identity, BinaryOperatoraccumulator)U reduce(U identity, BiFunctionaccumulator, BinaryOperatorcombiner)虽 ...继续阅读 (21)

你可能没意识到Java对函数式编程的重视程度，看看Java 8加入函数式编程扩充多少功能就清楚了。Java 8之所以费这么大功夫引入函数式编程，原因有二：代码简洁，函数式编程写出的代码简洁且意图明确，使用stream接口让你从此告别for循环。多核友好，Java函数式编程使得编写并行程序从未如此简单，你需要的全部就是调用一下parallel()方法。这一节我们学习stream，也就是Java函数式编程的主角。对于Java 7来说stream完全是个陌生东西，stream并不是某种数据结构，它只是数据源的一种视图。这里的数据源可以是一个数组，Java容器或I/O channel等。正因如此要得到一个stream通常不会手动创建，而是调用对应的工具方法，比如：调用Collection.stream()或者Collection.parallelStream()方法调用Arrays.stream(T[] array)方法常见的stream接口继承关系如图：图中4种stream接口继承自BaseStream，其中IntStream, LongStream, DoubleStream对应三种基本类型（int, long, double，注意不是包装类型），Stream对应所有剩余类型的stream视图。为不同数据类型设置不同stream接口，可以1.提高性能，2.增加特定接口函数。你可能会奇怪 ...继续阅读 (18)

正常情况下，JVM创建一个缓冲区的时候，实际上做了如下几件事：JVM确保Heap区域内的空间足够，如果不够则使用触发GC在内的方法获得空间;获得空间之后会找一组堆内的连续地址分配数组, 这里需要注意的是，在物理内存上，这些字节是不一定连续的;对于不涉及到IO的操作，这样的处理没有任何问题，但是当进行IO操作的时候就会出现一点性能问题.所有的IO操作都需要操作系统进入内核态才行，而JVM进程属于用户态进程, 当JVM需要把一个缓冲区写到某个Channel或Socket的时候，需要切换到内核态.而内核态由于并不知道JVM里面这个缓冲区存储在物理内存的什么地址，并且这些物理地址并不一定是连续的(或者说不一定是IO操作需要的块结构)，所以在切换之前JVM需要把缓冲区复制到物理内存一块连续的内存上, 然后由内核去读取这块物理内存，整合成连续的、分块的内存.为了解决这个问题, Java的某些版本会把物理区域分配好的部分内存做缓存就不用每次都开辟一块空间，但效果还不够好，毕竟复制的部分是少不了的.JDK1.4之后引入了NIO, 提供了一种内存映射技术, 让我们可以直接从Java代码中创建DirectBuffer，这种Buffer在创建的时候直接就在物理内存中分配一块连续内存，当需要使用的时候不再需要复制，内核直接调用即可. 但缺点也是显而易见的，就是每次分配都比较昂贵一点，同时由于分配的内存不在 ...继续阅读 (18)

一、前言不同的编程模型与具体的语言无关，大部分现代语言都可以通过巧妙地结构处理实现不同的模型.杂谈的意思是很杂，想到哪儿写到哪儿，不对正确性负责 :D.二、Actors模型传统的并发模型主要由两种实现的形式，一是同一个进程下，多个线程天然的共享内存，由程序对读写做同步控制(有锁或无锁). 二是多个进程通过进程间通讯或者内存映射实现数据的同步.Actors模型更多的使用消息机制来实现并发，目标是让开发者不再考虑线程这种东西，每个Actor最多同时只能进行一样工作，Actor内部可以有自己的变量和数据.Actors模型避免了由操作系统进行任务调度的问题，在操作系统进程之上，多个Actor可能运行在同一个进程(或线程)中.这就节省了大量的Context切换.在Actors模型中，每个Actor都有一个专属的命名”邮箱”, 其他Actor可以随时选择一个Actor通过邮箱收发数据,对于“邮箱”的维护，通常是使用发布订阅的机制实现的，比如我们可以定义发布者是自己，订阅者可以是某个Socket接口，另外的消息总线或者直接是目标Actor.目前akka库是比较流行的Actors编程模型实现，支持Scala和Java语言.三、CSP模型CSP(Communicating Sequential Process)模型提供一种多个进程公用的“管道(channel)”, 这个channel中存放的是一个个 ...继续阅读 (21)

模块间调用在一个应用系统中，无论使用何种语言开发，必然存在模块之间的调用，调用的方式分为几种：（1）同步调用同步调用是最基本并且最简单的一种调用方式，类A的方法a()调用类B的方法b()，一直等待b()方法执行完毕，a()方法继续往下走。这种调用方式适用于方法b()执行时间不长的情况，因为b()方法执行时间一长或者直接阻塞的话，a()方法的余下代码是无法执行下去的，这样会造成整个流程的阻塞。（2）异步调用异步调用是为了解决同步调用可能出现阻塞，导致整个流程卡住而产生的一种调用方式。类A的方法方法a()通过新起线程的方式调用类B的方法b()，代码接着直接往下执行，这样无论方法b()执行时间多久，都不会阻塞住方法a()的执行。但是这种方式，由于方法a()不等待方法b()的执行完成，在方法a()需要方法b()执行结果的情况下（视具体业务而定，有些业务比如启异步线程发个微信通知、刷新一个缓存这种就没必要），必须通过一定的方式对方法b()的执行结果进行监听。在Java中，可以使用Future+Callable的方式做到这一点，具体做法可以参见我的这篇文章Java多线程21：多线程下其他组件之CyclicBarrier、Callable、Future和FutureTask。（3）回调最后是回调，回调的思想是：类A的a()方法调用类B的b()方法类B的b()方法执行完毕主动调用类A的callba ...继续阅读 (23)

问题描述业务有一个需求，我把问题描述一下：通过代理IP访问国外某网站N，每个IP对应一个固定的网站N的COOKIE，COOKIE有失效时间。 并发下，取IP是有一定策略的，取到IP之后拿IP对应的COOKIE，发现COOKIE超过失效时间，则调用脚本访问网站N获取一次数据。 为了防止多线程取到同一个IP，同时发现该IP对应的COOKIE失效，同时去调用脚本更新COOKIE，针对IP加了锁。为了保证锁的全局唯一性，在锁前面加了标识业务的前缀，使用synchronized(lock){...}的方式，锁住"锁前缀+IP"，这样保证多线程取到同一个IP，也只有一个IP会更新COOKIE。不知道这个问题有没有说清楚，没说清楚没关系，写一段测试代码：public class StringThread implements Runnable { private static final String LOCK_PREFIX = "XXX---"; private String ip; public StringThread(String ip) { this.ip = ip; } @Override public void run() { String lock = buildLock(); ...继续阅读 (17)

1、实现功能向关注了微信公众号的微信用户群发消息。（可以是所有的用户，也可以是提供了微信openid的微信用户集合）2、基本步骤前提：已经有认证的公众号或者测试公众账号发送消息步骤：发送一个请求微信去获取access_token发送一个请求去请求微信发送消息相关微信接口的信息可以查看：http://www.cnblogs.com/0201zcr/p/5866296.html有测试账号的申请 + 获取access_token和发送微信消息的url和相关的参数需求。各个参数的意义等。3、实践这里通过HttpClient发送请求去微信相关的接口。1）maven依赖org.apache.httpcomponentshttpclient4.3.12）httpClient使用方法使用HttpClient发送请求、接收响应很简单，一般需要如下几步即可。创建HttpClient对象。创建请求方法的实例，并指定请求URL。如果需要发送GET请求，创建HttpGet对象；如果需要发送POST请求，创建HttpPost对象。如果需要发送请求参数，可调用HttpGet、HttpPost共同的setParams(HetpParams params)方法来添加请求参数；对于HttpPost对象而言，也可调用setEntity(HttpEntity entity)方法来设置请求参数。调用HttpClient对象 ...继续阅读 (26)

WARNING:这是七年前的一篇文章…这个方法不适用于大量数据，仅仅是提供一种使用SVD的思路.某天，一群《Family Guy》的粉丝们聚在一起，决定创建一个网站来分享各自喜欢的电视和对他们的评分，不久之后他们就获得了一个不错的网站，然后又有一大群人蜂拥而至和他们一起评分、分享，互相推荐电视剧集. 但由于用户越来越多，逐个查看某个人的评分记录，给她推荐电影越来越费事儿. 于是有人提出应该使用所有人的集体智慧来为每一个单独的人提供建议，这个过程应该是自动化的.是不是看起来很熟悉？没错，这就是推荐系统的雏形.现在已经有了无数的论文描述如何通过复杂的算法来实现推荐系统，但目前为止最有效、最常用同时也是最简单的方法是: 奇异值分解(SVD), 也常被用于潜在语义索引和降维处理.线性代数背景知识SVD的背景知识可以简单描述为以下内容：任何一个MxN的矩阵A，如果它的行数M大于或等于它的列数N，那么它就可以被转换成以下三个矩阵的乘积:一个MxM的正交矩阵U, 一个MxN的对角矩阵W(奇异值矩阵), 和一个正交矩阵V的转置矩阵.更直观的说，如果我们有一个矩阵，每一行代表一个产品, 每一行中的所有用户对该产品的评分. 因此我们有了M个产品，N个用户的矩阵MxN.根据上面的理论，我们可以把这个矩阵分解为 MxM 的矩阵U, MxN 的奇异值矩阵S和 NxN 的矩阵V. 最棒的是，我们可以通过S矩阵 ...继续阅读 (25)

1. I/O优化增加缓存，减少磁盘的访问次数。优化磁盘的管理系统，设计最优的磁盘方式策略，以及磁盘的寻址策略，这是在底层操作系统层面考虑的。设计合理的磁盘存储数据块，以及访问这些数据库的策略，这是在应用层面考虑的。例如，我们可以给存放的数据设计索引，通过寻址索引来加快和减少磁盘的访问量，还可以采用异步和非阻塞的方式加快磁盘的访问速度。应用合理的RAID策略提升磁盘I/O。2. Web前端调优减少网络交互的次数（多次请求合并）减少网络传输数据量的大小(压缩)尽量减少编码（尽量提前将字符转化为字节，或者减少从字符到字节的转化过程。）使用浏览器缓存减少Cookie传输合理布局页面使用页面压缩延迟加载页面CSS在最上面，JS在最下面CDN反向代理页面静态化异地部署3.服务降级（自动优雅降级）拒绝服务和关闭服务4.幂等性设计有些服务天然具有幂等性，比如讲用户性别设置为男性，不管设置多少次，结果都一样。但是对转账交易等操作，问题就会比较复杂，需要通过交易编号等信息进行服务调用有效性校验，只有有效的操作才能继续执行。（注：幂等性是系统的接口对外一种承诺(而不是实现), 承诺只要调用接口成功, 外部多次调用对系统的影响是一致的. 声明为幂等的接口会认为外部调用失败是常态, 并且失败之后必然会有重试.）5.失效转移若数据服务器集群中任何一台服务器宕机，那么应用程序针对这台服务器的所有读写操作都需要重 ...继续阅读 (16)

1、报错信息java.security.cert.CertificateException: No name matching api.weibo.com found; nested exception is javax.net.ssl.SSLHandshakeException: java.security.cert.CertificateException: No name matching api.weibo.com found原因：在调用api.weibo.com的时候，我们使用的是https的方式，正常情况下应该是使用api.weibo.com的证书，但由于某些原因，我们只能使用自己的证书，导致在验证证书的时候，就报了这个错误。解决的办法：忽略服务端和客户端的证书校验即可。java 提供的相关的类。2、具体实现方式通过重写TrustManager的checkClientTrusted（检查客户端证书信任）和checkServerTrusted（检查服务端证书验证）。以及HostnameVerifier的verify（校验）方法即可取消对证书的所有验证。import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.net.ssl.*; import java.io.IOException; im ...继续阅读 (19)

后续补充：这篇文章已经很久了，当初的设想是单机编程，每台服务器获得自己能够卖出多少产品，用户被随机分配到每台机器上进行处理。一、题目1, 这是一个秒杀系统，即大量用户抢有限的商品，先到先得2, 用户并发访问流量非常大, 需要分布式的机器集群处理请求3, 系统实现使用Java二、模块设计1, 用户请求分发模块：使用Nginx或Apache将用户的请求分发到不同的机器上。2, 用户请求预处理模块：判断商品是不是还有剩余来决定是不是要处理该请求。3, 用户请求处理模块：把通过预处理的请求封装成事务提交给数据库，并返回是否成功。4, 数据库接口模块：该模块是数据库的唯一接口，负责与数据库交互，提供RPC接口供查询是否秒杀结束、剩余数量等信息。第一部分就不多说了，配置HTTP服务器即可，这里主要谈谈后面的模块。用户请求预处理模块经过HTTP服务器的分发后，单个服务器的负载相对低了一些，但总量依然可能很大，如果后台商品已经被秒杀完毕，那么直接给后来的请求返回秒杀失败即可，不必再进一步发送事务了，示例代码可以如下所示：package seckill; import org.apache.http.HttpRequest; /** * 预处理阶段，把不必要的请求直接驳回，必要的请求添加到队列中进入下一阶段. */ public class PreProcessor { // 商品是否还 ...继续阅读 (27)

在之前我们分析SpringBoot的自动化配置原理的时候，分析了freemarker的自动化配置类FreeMarkerAutoConfiguration，这个自动化配置类需要classloader中的一些类需要存在并且在其他的一些配置类之后进行加载。但是还存在一些自动化配置类，它们需要在使用一些注解开关的情况下才会生效。比如spring-boot-starter-batch里的@EnableBatchProcessing注解、@EnableCaching等。一个需求在分析这些开关的原理之前，我们来看一个需求：定义一个Annotation，让使用了这个Annotaion的应用程序自动化地注入一些类或者做一些底层的事情。我们会使用Spring提供的@Import注解配合一个配置类来完成。我们以一个最简单的例子来完成这个需求：定义一个注解EnableContentService，使用了这个注解的程序会自动注入ContentService这个bean。@Retention(RetentionPolicy.RUNTIME) @Target(ElementType.TYPE) @Import(ContentConfiguration.class) public @interface EnableContentService {} public interface ContentService ...继续阅读 (17)

常用Shell命令查看网络状况netstat -n | awk '/^tcp/ {++S[$NF]} END {for(a in S) print a, S[a]}'使用top去获取进程cpu使用率；使用/proc文件查看进程所占内存。#!/bin/bash for i in `ps -ef | egrep -v "awk|$0" | awk '/'$1'/{print $2}'` do mymem=`cat /proc/$i/status 2> /dev/null | grep VmRSS | awk '{print $2" " $3}'` cpu=`top -n 1 -b |awk '/'$i'/{print $9}'` done常用JDK命令查看类的一些信息，如字节码的版本号、常量池等javap -verbose classname查看jvm进程jpsjcmd -l查看进程的gc情况jstat -gcutil [pid] (显示总体情况)jstat -gc [pid] 1000 10（每隔1秒刷新一次 一共10次）查看jvm内存使用状况jmap -heap [pid]查看jvm内存存活的对象：jcmd [pid] GC.c ...继续阅读 (12)

在之前的文章中，我们分析过SpringBoot内部的自动化配置原理和自动化配置注解开关原理。我们先简单分析一下mybatis starter的编写，然后再编写自定义的starter。mybatis中的autoconfigure模块中使用了一个叫做MybatisAutoConfiguration的自动化配置类。这个MybatisAutoConfiguration需要在这些Condition条件下才会执行：@ConditionalOnClass({ SqlSessionFactory.class, SqlSessionFactoryBean.class })。需要SqlSessionFactory和SqlSessionFactoryBean在classpath中都存在@ConditionalOnBean(DataSource.class)。 spring factory中需要存在一个DataSource的bean@AutoConfigureAfter(DataSourceAutoConfiguration.class)。需要在DataSourceAutoConfiguration自动化配置之后进行配置，因为mybatis需要数据源的支持同时在META-INF目录下有个spring.factories这个properties文件，而且它的key为org.springframework.b ...继续阅读 (27)

前言废话不多说，直接进入文章。我们在使用mybatis的时候，会在xml中编写sql语句。比如这段动态sql代码：UPDATE usersname = #{name}, age = #{age}, birthday = #{birthday}where id = ${id}mybatis底层是如何构造这段sql的？这方面的知识网上资料不多，于是就写了这么一篇文章。下面带着这个疑问，我们一步一步分析。介绍MyBatis中一些关于动态SQL的接口和类SqlNode接口，简单理解就是xml中的每个标签，比如上述sql的update,trim,if标签：public interface SqlNode { boolean apply(DynamicContext context); }SqlSource Sql源接口，代表从xml文件或注解映射的sql内容，主要就是用于创建BoundSql，有实现类DynamicSqlSource(动态Sql源)，StaticSqlSource(静态Sql源)等：public interface SqlSource { BoundSql getBoundSql(Object parameterObject); }BoundSql类，封装mybatis最终产生sql的类，包括sql语句，参数，参数源数据等参数：XNode，一个Dom API中的Nod ...继续阅读 (33)

前方高能！ 本文内容有点多，通过实际测试例子+源码分析的方式解剖MyBatis缓存的概念，对这方面有兴趣的小伙伴请继续看下去~MyBatis缓存介绍首先看一段wiki上关于MyBatis缓存的介绍：MyBatis支持声明式数据缓存（declarative data caching）。当一条SQL语句被标记为“可缓存”后，首次执行它时从数据库获取的所有数据会被存储在一段高速缓存中，今后执行这条语句时就会从高速缓存中读取结果，而不是再次命中数据库。MyBatis提供了默认下基于Java HashMap的缓存实现，以及用于与OSCache、Ehcache、Hazelcast和Memcached连接的默认连接器。MyBatis还提供API供其他缓存实现使用。重点的那句话就是：MyBatis执行SQL语句之后，这条语句就是被缓存，以后再执行这条语句的时候，会直接从缓存中拿结果，而不是再次执行SQL这也就是大家常说的MyBatis一级缓存，一级缓存的作用域scope是SqlSession。MyBatis同时还提供了一种全局作用域global scope的缓存，这也叫做二级缓存，也称作全局缓存。一级缓存测试同个session进行两次相同查询：@Test public void test() { SqlSession sqlSession = sqlSessionFactory.openS ...继续阅读 (19)

SpringBatch是spring框架下的一个子模块，用于处理批处理的批次框架。本文主要分析SpringBatch中的retry和skip机制的实现。先简单说明下SpringBatch在SpringBoot中的使用。如果要在springboot中使用batch的话，直接加入以下依赖即可：org.springframework.bootspring-boot-starter-batch然后使用注解开启Batch模块：... @EnableBatchProcessing public class Application { ... }之后就可以注入JobBuilderFactory和StepBuilderFactory：@Autowired private JobBuilderFactory jobs; @Autowired private StepBuilderFactory steps;有了这2个factory之后，就可以build job。SpringBatch中的相关基础概念比如ItemReader、ItemWriter、Chunk等本文就不介绍了。我们以FlatFileItemReader作为reader，一个自定义Writer用于打印reader中读取出来的数据。这个定义的writer遇到good job这条数据的时候会报错，具体逻辑如下：@Override publi ...继续阅读 (22)

MyBatis拦截器介绍MyBatis提供了一种插件(plugin)的功能，虽然叫做插件，但其实这是拦截器功能。那么拦截器拦截MyBatis中的哪些内容呢？我们进入官网看一看：MyBatis 允许你在已映射语句执行过程中的某一点进行拦截调用。默认情况下，MyBatis 允许使用插件来拦截的方法调用包括：Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed)ParameterHandler (getParameterObject, setParameters)ResultSetHandler (handleResultSets, handleOutputParameters)StatementHandler (prepare, parameterize, batch, update, query)我们看到了可以拦截Executor接口的部分方法，比如update，query，commit，rollback等方法，还有其他接口的一些方法等。总体概括为：拦截执行器的方法拦截参数的处理拦截结果集的处理拦截Sql语法构建的处理拦截器的使用拦截器介绍及配置首先我们看下MyBatis拦截器的接口定义：public interface Interceptor { ...继续阅读 (10)

Springboot内部提供的事务管理器是根据autoconfigure来进行决定的。比如当使用jpa的时候，也就是pom中加入了spring-boot-starter-data-jpa这个starter之后(之前我们分析过springboot的自动化配置原理)。Springboot会构造一个JpaTransactionManager这个事务管理器。而当我们使用spring-boot-starter-jdbc的时候，构造的事务管理器则是DataSourceTransactionManager。这2个事务管理器都实现了spring中提供的PlatformTransactionManager接口，这个接口是spring的事务核心接口。这个核心接口有以下这几个常用的实现策略：HibernateTransactionManagerDataSourceTransactionManagerJtaTransactionManagerJpaTransactionManager具体的PlatformTransactionManager继承关系如下：spring-boot-starter-data-jpa这个starter会触发HibernateJpaAutoConfiguration这个自动化配置类，HibernateJpaAutoConfiguration继承了JpaBaseConfigurati ...继续阅读 (13)

最国产的方式，就是使用百度API了，百度提供了两种服务：普通的IP服务：http://lbsyun.baidu.com/index.php?title=webapi/ip-apihttps://api.map.baidu.com/location/ip?ak=请输入您的AK&coor;=bd09ll返回值:{ address: "CN|吉林|长春|None|CERNET|1|None", content: { address: "吉林省长春市", address_detail: { city: "长春市", city_code: 53, district: "", province: "吉林省", street: "", street_number: "" }, point: { x: "125.31364243", y: "43.89833761" } }, ...继续阅读 (30)

记录一下自己理解的一些设计模式，并尽量使用表达清楚的例子进行讲解。策略模式策略模式应该是最基础的一个设计模式，它是对行为的一个抽象。jdk中的Comparator比较器就是一个使用策略设计模式的策略。比如有一个Student学生类，有name和age两个属性。如果有个需求需要打印学生名单，并按照字母顺序排序，可以使用Comparator接口并在内部使用name进行比较即可。 如果哪一天需要按照年龄进行排序，那么只需要修改Comparator即可，也就是使用一个新的策略，其它完全不变。工厂模式工厂模式的意义在于对象的创建、管理可以使用工厂去管理，而不是创建者自身。最典型的工厂模式使用者就是Spring，Spring内部的容器就是一个工厂，所有的bean都由这个容器管理，包括它们的创建、销毁、注入都被这个容器管理。工厂模式分简单工厂和抽象工厂。它们的区别在于抽象工厂抽象程度更高，把工厂也抽象成了一个接口，这样可以再每添加一个新的对象的时候而不需要修改工厂的代码。比如有个Repository接口，用于存储数据，有DatabaseRepository，CacheRepository，FileRepository分别在数据库，缓存，文件中存储数据，定义如下：public interface Repository { void save(Object obj); } class Da ...继续阅读 (23)

2.6版本之后支持嵌入Lua脚本，客户端使用Lua脚本，直接在服务器端原子的执行多条命令Lua脚本执行过程创建并修改Lua环境1 创建基础Lua环境2 载入函数库3 创建全局表格Lua4 替换随机函数5 创建排序辅助函数6 创建redis.pcall函数7 全局环境保护8 修改后的Lua环境保存到服务器状态的Lua属性，等待脚本执行Redis中带有不确定性的命令：SINTER SUNION SDIFF SMEMEBERS HKEYS HVALS KEYS注意：Redis提供了排序函数，使用上述命令后，会返回相同的排序结果Redis确保检查创建变量时，添加local等参数，但是没有禁止修改已经存在的全局变量，因此使用时应谨慎。由于Redis使用串行化的方式执行，因此某一特定时间，只有一个脚本能被放进Lua环境里面运行。环境协作组件环境组件：一个是用于执行Lua脚本的伪客户端一个用于保存Lua脚本的字典。执行Lua脚本的伪客户端使用redis.call或者redis.pcall执行Redis命令：1 将redis.call或者redis.pcall传给伪客户端2 伪客户端将执行的命令传给执行器3 执行器执行命令，返回给伪客户端4 伪客户端把结果返回给Lua环境5 Lua环境把结果返回给redis.call或者redis.pcall函数6 redis.call或者redis.pcall返 ...继续阅读 (13)

发布订阅中使用到的命令就只有三个：PUBLISH,SUBSCRIBE,PSUBSCRIBEPUBLISH 用于发布消息SUBSCRIBE 也叫频道订阅，用于订阅某一特定的频道PSUBSCRIBE 也叫模式订阅，用于订阅某一组频道，使用glob的方式，比如xxx-*可以匹配xxx-a，和xxx-b,xxx-ddd等等订阅频道: pubsub_channels关联操作：如果已经存在订阅者，则添加到链表的尾部如果没有订阅者，那么创建频道，然后添加订阅者删除操作：找到对应的链表，进行删除如果删除后，链表为空，则删除频道模式订阅: pubsub_patternsclient-7订阅music.* client-8订阅book.* client-9订阅news.*订阅模式：新建一个pubsubPattern结构添加到链表的尾部退订模式：查找相应的pubsubPattern然后删除发送消息：将消息发送给channel频道的所有订阅者遍历整个pubsub_patterns表，查找匹配的模式，如果有一个或者多个模式与频道匹配，将消息发送给pattern模式的订阅者相关命令：查看所有的频道：PUBSUB CHANNELS查询订阅者的数量：PUBSUB NUMSUB查询服务器被订阅者的数量：PUBSUB NUMPAT相关文章Redis Lua脚本原理如何使用Jedis操作Redis消息队列Linux下安 ...继续阅读 (24)