peter peter
4年前
Go:分布式锁实现原理与最佳实践
分布式锁应用场景很多应用场景是需要系统保证幂等性的(如api服务或消息消费者),并发情况下或消息重复很容易造成系统重入,那么分布式锁是保障幂等的一个重要手段。另一方面,很多抢单场景或者叫交易撮合场景,如dd司机抢单或唯一商品抢拍等都需要用一把“全局锁”来解决并发造成的问题。在防止并发情况下造成库存超卖的场景,也常用分布式锁来解决。实现
认知篇:CQRS架构模式的本质
CQRS只是一种非常简单的模式(pattern),CQRS本身并不是一种架构风格,和最终一致性/消息/读写分离/事件溯源/DDD等没有必然的联系,它最大优势是给我们带来更多的架构属性选择
Stella981 Stella981
3年前
SpringBoot如何优雅的使用RocketMQ
目录SpringBoot如何优雅的使用RocketMQ什么是RocketMQ?RocketMQ环境安装SpringBoot环境中使用RocketMQSpringBoot如何优雅的使用RocketMQMQ,是一种跨进程的通信机制,用于上下游传递消息。在传统的互联网架构中通常使用M
Stella981 Stella981
3年前
Kafka源码剖析 —— 生产者消息追加中的优秀设计与大体流程
消息发送流程:!这里写图片描述(https://imgblog.csdn.net/20180905170801267?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FudXJub21lcnU/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA/disso
Easter79 Easter79
3年前
SpringBoot如何优雅的使用RocketMQ
目录SpringBoot如何优雅的使用RocketMQ什么是RocketMQ?RocketMQ环境安装SpringBoot环境中使用RocketMQSpringBoot如何优雅的使用RocketMQMQ,是一种跨进程的通信机制,用于上下游传递消息。在传统的互联网架构中通常使用M
Stella981 Stella981
3年前
KafkaProducer Sender 线程详解(含详细的执行流程图)
\温馨提示:本文基于Kafka2.2.1版本。上文《源码分析Kafka消息发送流程》(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fblog.csdn.net%2Fprestigeding%2Farticle%2Fdetails%2F102994716)已经详细介绍
Wesley13 Wesley13
3年前
ActiveMQ的慢消费者
慢消费者:消费消息过慢的consumer/subscriber。慢消费者会对broker产生影响,尤其是nondurable的topic和queue,topic尤甚,会导致broker的内存爆满,阻塞publisher。1\.NondurableTopics受慢消费者影像最大,发送到nond
Stella981 Stella981
3年前
IOS开发网络阶段之NSURLSession
//// ViewController.m// 02NSURLSession//// Createdby鹿微微鹿on16/4/27.// Copyright(c)2016年鹿微微鹿.Allrightsreserved.////在这里总结一个方法,通过参数返回另一个页面一个消息或者其他东西//可以把
Stella981 Stella981
3年前
Redis配置讲解及实战
前言Redis是一个开源的内存kv数据库,同时也可用作缓存,消息队列。支持多种数据类型,如字符串,列表,字典,集合,有序集合。演示环境$unameaDarwin18.6.0DarwinKernelVersion18.6.0:ThuApr2523:16:27PDT2019;root:
Wesley13 Wesley13
3年前
JavaWeb项目架构之Kafka分布式日志队列
架构、分布式、日志队列,标题自己都看着唬人,其实就是一个日志收集的功能,只不过中间加了一个Kafka做消息队列罢了。!(https://images2017.cnblogs.com/blog/109211/201802/109211201802061533201231622886397.png)kafka介绍Kafka是由