//安装类库 composer require php-amqplib/php-amqplib //consumer.php消费者代码 require __DIR__ . "/../vendor/autoload.php"; use PhpAmqpLib\Connection\AMQPStreamC ...
分类：
Web程序 时间：
2021-03-08 13:44:12
阅读次数：
0
目录 一、Kafka监控的几个指标 二、查看zookeeper配置 三、查看kafka配置 四、查看kafka的group name 五、查看kafka的topic_name 六、修改zabbix配置文件 七、创建监控脚本 八、给脚本和对应文件权限 九、重启zabbix 十、监控上增加3个键值 正文 ...
分类：
其他好文 时间：
2021-03-03 12:11:41
阅读次数：
0
首先本人还没有学习过rabbitmq，还不太知道其exchange和queue的存储和消费的机制。下面是个人的理解，日后要是学习了rabbitmq再来更正 springcloud-stream目前案例是使用rabbitmq作为支持，现在默认的destination是topic形式，不同的微服务实例会 ...
分类：
编程语言 时间：
2021-02-27 13:17:37
阅读次数：
0
Object中有两个涉及到了线程的方法： void wait()：让当前线程进入等待状态，直到被唤醒；（会释放锁） void notify()：唤醒当前正在等待的线程。（只会通知，不会释放锁） 因为Object是所有类的鼻祖，所以每一个对象都拥有wait()和notify()。 生产者和消费者模型 ...
分类：
其他好文 时间：
2021-02-24 13:12:42
阅读次数：
0
通常的PCB设计电流都不会超过10A，甚至5A。尤其是在家用、消费级电子中，通常PCB上持续的工作电流不会超过2A。但是最近要给公司的产品设计动力走线，持续电流能达到80A左右，考虑瞬时电流以及为整个系统留下余量，动力走线的持续电流应该能够承受100A以上。那么问题就来了，怎么样的PCB才能承受住1 ...
分类：
其他好文 时间：
2021-02-22 12:38:52
阅读次数：
0
Exchanger的功能可以使2个线程之间传输数据,它比生产者消费者模式使用的wait/notify要更加方便,类Exchanger中的exchange()方法具有阻塞的特色,也就是此方法被调用后等待其他线程来取得数据，如果没有其他线程取得数据，则一直阻塞等待。Exchanger主要有两个方法 :e ...
分类：
编程语言 时间：
2021-02-22 12:34:21
阅读次数：
0
线上有一个消息消费服务，主线程批量从kafka拉取消息，然后提交到子线程池中挨个消费。分布式追踪用到的kafka插件会使子线程创建的ThreadLocalScope被循环引用，从而造成内存泄漏。 ...
分类：
其他好文 时间：
2021-02-20 11:53:15
阅读次数：
0
面试官心理分析 其实这是很常见的一个问题，这俩问题基本可以连起来问。既然是消费消息，那肯定要考虑会不会重复消费？能不能避免重复消费？或者重复消费了也别造成系统异常可以吗？这个是 MQ 领域的基本问题，其实本质上还是问你使用消息队列如何保证幂等性，这个是你架构里要考虑的一个问题。 面试题剖析 回答这个 ...
分类：
其他好文 时间：
2021-02-19 13:44:49
阅读次数：
0
queue模块实现了多生产者,多消费者队列 queue模块的常用类和异常 queue.Queue(maxsize=0) 先进先出(FIFO)的队列, maxsize: 队列的大小(即队列的元素个数),默认0,队列大小无限;如果超过maxsize,队列会加锁,添加新元素是被堵塞,直到队列中的元素小于m ...
分类：
编程语言 时间：
2021-02-19 13:10:44
阅读次数：
0
1.三个多线程可能引起的问题 package other; public class UnSafeTicker implements Runnable { private int ticket=10; boolean flag=true; @Override public void run() { ...
分类：
编程语言 时间：
2021-02-08 12:09:22
阅读次数：
0
