概述canal client将从canal server获取的binlog数据以json格式发送到各种MQ中(rabbitmq，redis，kafka)。部署第一步：下载解压项目，使用的是与canal-server 1.0.22版本对应的client（canal-client-1.0.22.tar. ...
分类：
其他好文 时间：
2020-04-29 18:12:34
阅读次数：
229
1、链式调用方式 服务A 事务方法的最后一行 调用服务B事务方法， 服务B事务方法的最后一行 调用服务C事务方法 因为都是每个方法的最后一行，从上往下执行，如果有任何一个服务出现问题，那么整条链路都会回滚事物 2、通过mq自己手动回滚业务（补偿事务（TCC）） 比如订单提交，可以先在订单服务完成订单 ...
分类：
其他好文 时间：
2020-04-29 12:50:07
阅读次数：
47
一轮 hashmap源码问题 HashMap底层结构 put操作讲一下 HashMap、HashMap如何保证线程安全、ConcurrentHashMap JVM有哪些回收算法，对应的收集器有哪些？ jvm g1的内存模型讲一下，G1和CMS收集器的区别？以及G1收集器对CMS的改进？ java线程 ...
分类：
其他好文 时间：
2020-04-27 15:33:22
阅读次数：
84
2020-04-27 11:34:37.312 [SimpleAsyncTaskExecutor-37] ERROR org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer - Consumer received ...
分类：
其他好文 时间：
2020-04-27 13:31:02
阅读次数：
69
真的想尽快学完种种框架，综合搭建起一个项目来，然后看着他出Bug、慢慢地自己去优化，重构，再完善。 1. RabbitMQ的作用 笔者经常能看到MQ这个词，知道其作为消息队列，但始终没有接触过，现在刚好有个机会（不知道在抢答系统中能不能用上），首先当然要知道MQ有什么作用： 异步处理： 用户注册：注 ...
分类：
其他好文 时间：
2020-04-27 09:28:00
阅读次数：
48
MQ全称为Message Queue,是一种应用程序对应用程序的通信方法，应用程序通过读写出入消息队列的数据来通信，从而无需专用连接来链接他们（如RPC）。 消息队列是典型的生产者和消费者模型，生产者和消费者只关心消息的发送和接受，没有业务逻辑的侵入，实现了生产者和消费者的解耦。 AMQP：一个提供 ...
分类：
其他好文 时间：
2020-04-23 22:56:09
阅读次数：
72
1.原因描述 我们在工作中遇到耗时的一些操作时我们会使用多线程或者mq来解决以便提高程序的响应速度。但是使用多线程时遇到一个问题，我单独开一个线程去进行其他逻辑处理时，在发送消息之前(未开启多线程时)我们是可以获取到 request 信息的，但是在新开的线程中确是无法获取到 request 信息(r ...
分类：
编程语言 时间：
2020-04-22 19:48:49
阅读次数：
243
参考文档：https://www.cnblogs.com/ericli-ericli/p/5917018.html MQ的使用场景大概包括解耦，提高峰值处理能力，送达和排序保证，缓冲等。 MQ概述 消息队列技术是分布式应用间交换信息的一种技术。 消息队列可驻留在内存或磁盘上,队列存储消息直到它们被应 ...
分类：
其他好文 时间：
2020-04-21 09:45:03
阅读次数：
77
Flask单机测试，实现redis+MQ秒杀业务，防止超限 简单描述 抢购，秒杀是商场业务很常见的应用场景，主要需求解决： 1.高并发 2.如何解决库存的正确减少（"超卖"的问题） redis 命令说明exists >setnx> incrby # (1) 设置一些参数 # 限制商品库存总数 amo ...
分类：
其他好文 时间：
2020-04-20 09:15:19
阅读次数：
192
简介 RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而群集和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。支持主流的操作系统，多种开发语言支持。 什么是MQ 消 ...
分类：
其他好文 时间：
2020-04-18 13:35:28
阅读次数：
58
