springcloud(三)：Eureka服务端
一.因为使用一个注册中心服务器端，n个客户端：n个生产者客户端、n消费者客户端....,所有的客户端最好的方式就是通过对象传递参数，因此需要创建一个公共组件项目，为n个客户端传值提供方便二、创建公共组件项目1.创建公共组件项目，因为只是数据传输层共用，因此创建普通maven项目就好!(https://oscimg.osc
ActiveMQ的慢消费者
慢消费者：消费消息过慢的consumer/subscriber。慢消费者会对broker产生影响，尤其是nondurable的topic和queue，topic尤甚，会导致broker的内存爆满，阻塞publisher。1\.NondurableTopics受慢消费者影像最大，发送到nond
RabbitMQ之消息确认机制（事务+Confirm）
概述在使用RabbitMQ的时候，我们可以通过消息持久化操作来解决因为服务器的异常奔溃导致的消息丢失，除此之外我们还会遇到一个问题，当消息的发布者在将消息发送出去之后，消息到底有没有正确到达broker代理服务器呢？如果不进行特殊配置的话，默认情况下发布操作是不会返回任何信息给生产者的，也就是默认情况下我们的生产者是不知道消息有没有
ActiveMQ学习（六）
_消费者集群负载均衡_!(https://oscimg.oschina.net/oscnet/c6f4857e2e675380e23ec1f33dc45e08711.jpg)broker服务器集群已经做好了，现在来看怎么做消费者集群。就是一个broker端有很多的消费者，在这一个端的消费者之间是集群。消费者端可以用多线程来
4.kafka生产者
转: https://www.cnblogs.com/sodawoodsblogs/p/8969513.html(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblogs.com%2Fsodawoodsblogs%2Fp%2F8969513.html)（1）生产者
Kafka技术内幕 读书笔记之（三） 消费者：高级API和低级API——消费者再平衡操作
消费者再平衡操作消费者连接器的核心处理逻辑是再平衡操作，它起了承上启下的作用。初始化消费者连接器只是“创建了队列和消息流”，再平衡操作会“为消费者重新分配分区”。只有为消费者分配了分区，拉取线程才会开始拉取分区的消息。因为分区要被重新分配，分区的所有者都会发生变化 ，所以在还没有重新分配分区之前 ，所有消费者都要停止已有的拉取钱程 。
Kafka01
Kafka之生产者入门前言： Kafka诞生至今，产生两个版本的生产者客户端：1是早期基于scala语言编写的客户端；2是随着Java用户的广泛涌入，kafka0.9版本开始退出Java版本的客户端； 一个基本生产者producer逻辑需要具备以下基本条件：配置Producer，创建生产者实例；
Dubbo消费者
创建代理对象com.alibaba.dubbo.config.ReferenceConfigcreateProxy通过消费者get()方法可以找到以上方法，消费者需要根据配置的接口生成代理对象。协议生成InvokerDubboProtocolpublic<TInvoker<
RabbitMQ之概念介绍（二）
简介： MQ全称为MessageQueue，消息队列是一种应用程序间的通信方法。 其是消费者生产者模型的一个典型代表，一端往消息队列中不断写入消息，另一端不断读取/订阅消息。简单使用场景举例： 将项目中无需即时返回且耗时的操作提取出来，进行异步处理，大大降低了服务器的请求响应时间。 如：打印日志模块无需即时返回