多线程已经成为服务器开发不可或缺的重要知识点了，那么怎样协调各个线程之间的工作就变得至关重要，于是这篇文章就来总结一下线程同步的方法。 什么是线程同步？ “同”字应是指协同、协助、互相配合。主旨在协同步调，按预定的先后次序运行。线程同步：即当有一个线程在对内存进行操作时，其他线程都不可以对这个内存地 ...
分类：
编程语言 时间：
2020-05-25 09:29:28
阅读次数：
55
Consumer之自动提交在上文中介绍了ProducerAPI的使用，现在我们已经知道如何将消息通过API发送到Kafka中了，那么现在的生产者/消费者模型就还差一位扮演消费者的角色了。因此，本文将介绍ConsumerAPI的使用，使用API从Kafka中消费消息，让应用成为一个消费者角色。还是老样子，首先我们得创建一个Consumer实例，并指定相关配置项，有了这个实例对象后我们才能进行其他的操
Kafka快速入门（四）——Kafka高级功能一、Kafka无消息丢失配置1、Kafka消息丢失简介Kafka只针对已提交消息（committedmessage）做有限度的持久化保证。当Kafka的若干个Broker成功地接收到一条消息并写入到日志文件后，会通知生产者程序相应消息已成功提交。多少个Broker成功保存消息算是已提交，可以由Producer参数或Broker端参数指定。有限度的持久化
分类：
其他好文 时间：
2020-05-24 10:09:30
阅读次数：
56
Kafka快速入门（三）——Kafka核心技术一、生产者压缩算法1、Kafka消息压缩压缩（compression）是用时间换空间的经典trade-off思想，使用CPU时间换磁盘空间或网络I/O传输量，以较小的CPU开销带来更少的磁盘占用或更少的网络I/O传输。Kafka有两类消息格式，V1版本和V2版本，V2版本在Kafka0.11.0.0中正式引入。Kafka的消息层次都分为两层：消息集合（
分类：
其他好文 时间：
2020-05-24 09:37:17
阅读次数：
56
1. 什么是RabbitMQ MQ全称为Message Queue 消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息。消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等 ...
分类：
其他好文 时间：
2020-05-23 20:35:56
阅读次数：
65
1. 使用wait/notifyAll 实现 ...
分类：
编程语言 时间：
2020-05-23 18:30:03
阅读次数：
50
（1）在分布式系统下具备异步,削峰,负载均衡等一系列高级功能; （2）拥有持久化的机制，进程消息，队列中的信息也可以保存下来。 （3）实现消费者和生产者之间的解耦。 （4）对于高并发场景下，利用消息队列可以使得同步访问变为串行访问达到一定量的限流，利于数据库的操作。 （5）可以使用消息队列达到异步下 ...
分类：
其他好文 时间：
2020-05-22 21:48:05
阅读次数：
80
1.生产者 消费者问题 系统中有一组生产者进程和一组消费者进程，生产者进程每次生产一个产品放入缓冲区，消费者进程每次从缓冲区中取出一个产品并使用。 生产者、消费者共享一个初始为空、大小为n的缓冲区，各进程互斥访问 缓冲区没满时，生产者才能把产品放入缓冲区，否则必须等待 缓冲区不空时，消费者才能从中取 ...
分类：
系统相关 时间：
2020-05-19 20:58:50
阅读次数：
68
RabbitMQ介绍 生产者与消费者模型在编码的过程中,和生活中都较为常见,我可以把它比作一个缓冲的仓库, 如果再一次秒杀活动中,抢购的人太多,而后台订单处理的服务器明显不够, 订单过量就会导致宕机的风险,最简单的办法获取就是加服务器,可是秒杀结束了你要把它卸掉吗? 消息队列（MQ）是一种应用程序对 ...
分类：
其他好文 时间：
2020-05-19 09:11:15
阅读次数：
71
进入到命令行：./zkCli.sh -server 10.1.1.120:2181查看注册的dubbo服务：ls /查看dubbo服务提供的对外接口：ls /dubbo查看消费者：ls /dubbo/com.ipharmacare.engine.api.CacheApi/consumers查看生产者 ...
分类：
其他好文 时间：
2020-05-18 10:44:49
阅读次数：
51
