项目介绍 一款基于java语言，使用Springboot+Mongodb+Groovy+Es等框架搭建的轻量级实时风控引擎，适用于反欺诈应用场景，极简的配置，真正做到了开箱即用。 通过学习本项目能快速了解 风险的定义 ，进而 量化风险 ，最后达到 集中管理风险 的目的。 Areal-timeriskanalysisengine,whichcanupdateriskruleinreal-timeandmakeiteffectiveimmediately. Itappliestotheanti-fraudapplicationperfec...

作为一个Java开发线程池的使用是一个绕不过去的坎，如何正确的使用线程池是每个开发面临的问题，今天我们就从开源项目中来看看那些顶级开源项目中是如何使用线程池。下面我们就以笔者最近参与的开源项目RocketMQ为例子同时结合笔者在工作中遇到的一些使用一些不好的习惯来说一下线程池使用。会从一下几个方面来说： 1\.线程池的创建 首先我们看一下RocketMQ的线程创建方式，以​​BrokerControllerinitializeResources​​ 初看一下好像是自定义的线程池，查看源码就会发现​​BrokerFixedThreadPoolExecutor​​​其实是实现了​​Thread...

前言 Ribbon作为SpringCloud全家桶核心组件之一，是一套基于客户端的软负载工具，主要是基于Netfilx发布的开源项目，功能主要是应用于客户端软件的负载均衡算法、服务之间调用的桥梁。作为客户端的组件，提供了一系列的配置，如拒绝策略、超时重试、服务发现策略….主要的核心组件也是基于LoadBalancer，会提供一些负载均衡策略，如轮询、加权轮询、随机连接、重试等策略。 注册中心、负载均衡、生产者服务之间的注册与调用情况 关于ribbon是如何实现服务之间调用的，可以看我之前写的一篇文章​​Feign远程调用原理分析掘金​​，Feign基于ribbon做远程调用 Ribbon负载...

前言 工作中使用​​OpenFeign​​进行跨服务调用，最近发现线上经常会遇到请求失败。 java.net.ConnectException:Connectionrefused:connect复制代码 通过排查我们发现不是接口超时，而是有时候会请求到已经下线的服务导致报错。这多发生在服务提供者系统部署的时候，因为系统部署的时候会调用​​Spring​​容器的​​shutdown()​​方法，​​EurekaServer​​那里能够及时的剔除下线服务，但是我们上一篇文章中已经知道​​readOnlyCacheMap​​和​​readWriteCacheMap​​同步间隔是​​30S...