Aloha

pagecache回顾我的zerocopy的文章，我们可以发现，其中第一步都是需要先把磁盘文件数据拷贝到内存缓冲区，这个内存缓冲区就是pagecache 由于零拷贝使用到了pagecache，所以零拷贝技术的性能得到了进一步的提升。 读写磁盘的速度相比于读写内存的速度慢太多，所以我们应该把读写磁盘替换成读写内存。 但是我们知道读写内存具有局限性，pagecache就使用了预读的功能，读磁盘数据的时候，如果read方法每次只读前32k的内容，但是内核会把32～64kb的字节也读取出来 这时候，pagecache的优点有两个： 缓存最近呗访问的数据 预读功能 kafkakafka重度依赖于底层操作系统的pagecache的功能 kafka为什么不自己管理缓存，而是使用pagecache，理由如下： JVM中一切皆对象，数据的对象存储会带来所谓object overhead，浪费空间； 如果由JVM来管理缓存，会受到GC的影响，并且过大的堆也会拖累GC的效率，降低吞吐量； 一旦程序崩溃，自己管理的缓存数据会全部丢失。 我们来看一下kafka的两大核心组件如何引入cache的功能的 ...

AOPSpring 框架通过定义切面, 通过拦截切点实现了不同业务模块的解耦，这个就叫面向切面编程 - Aspect Oriented Programming (AOP) AOP在Spring中的作用 横切关注点：跨越应用程序多个模块的方法或功能。即是，与我们业务逻辑无关的，但是我们需要关注的部分，就是横切关注点。如日志 , 安全 , 缓存 , 事务等等 …. 切面（ASPECT）：横切关注点 被模块化 的特殊对象。即，它是一个类。 通知（Advice）：切面必须要完成的工作。即，它是类中的一个方法。 目标（Target）：被通知对象。 代理（Proxy）：向目标对象应用通知之后创建的对象。 切入点（PointCut）：切面通知 执行的 “地点”的定义。 连接点（JointPoint）：与切入点匹配的执行点。 AOP的实现方式通过Spring API实现1234567//首先实现一个接口类public interface UserService { public void add(); public void delete(); public void ...

由于国内的支付方式都需要商家资质，沙盒环境都不能使用，因此在这里记录一下paypal的接入过程 前提准备去开发环境获取clientId以及token接着去curl生成一个产品 1234567891011curl -v -X POST https://api-m.sandbox.paypal.com/v1/catalogs/products -H "Content-Type: application/json" -H "Authorization: Bearer ACCESS-TOKEN" -H "PayPal-Request-Id: REQUEST-ID" -d '{ "name": "Video Streaming Service", "description": "A video streaming service", "type": "SERVICE", &qu ...

为什么需要网关什么是服务网关传统的单体架构中只需要开放一个服务给客户端调用，但是微服务架构中是将一个系统拆分成多个微服务，如果没有网关，客户端只能在本地记录每个微服务的调用地址，当需要调用的微服务数量很多时，它需要了解每个服务的接口，这个工作量很大。 微服务网关的基本功能 对比一下不同的网关这里对比一下gateway 和 zuulgateway 网关：功能强大丰富，性能好，官方基准测试 RPS (每秒请求数)是Zuul的1.6倍，能与 SpringCloud 生态很好兼容，单从流式编程+支持异步上也足以让开发者选择它了。 （4）Zuul 2.x：性能与 gateway 差不多，基于非阻塞的，支持长连接，但 SpringCloud 没有集成 zuul2 的计划，并且 Netflix 相关组件都宣布进入维护期，前景未知。 实践如何集成在项目中 在 Spring Cloud Gateway 中，我通过自定义 Zuul 过滤器 LoginFilter 实现了路由鉴权。LoginFilter 继承自 AbstractPreZuulFilter，属于前置过滤器，在请求路由之前执行鉴权逻辑。以下是实 ...

场景在我的项目中，有遇到一个需要定期给用户转账的场景，但是最开始的想法是使用spring schduled来进行做定时任务，但是由于做逻辑的时候发现如果使用schduled来进行延迟性比较大，最后在网上查阅资料后发现可以使用redis的delayed queue来做定时任务，但是redis只能在单机节点上进行，如果在分布式场景下会导致重复消费，因此使用了redission来进行实现，同时在使用redission后为了保证交易的准确性，加入了xxl-job来做分布式分片广播定时任务来确保交易的完整性 实践 在使用redission的时候需要实现两个队列 12RBlockingQueue<T> rBlockingQueue = redissonClient.getBlockingQueue(queueName);RDelayedQueue<T> delayedQueue = redissonClient.getDelayedQueue(rBlockingQueue); 第一个阻塞队列是添加已经到时间的资源第二个是一个延迟队列接受传入的资源，并且进行到点弹出 启 ...