上节说了kafka在linux环境下怎么搭建集群。这节写一下怎么在springcloud中以stream流方式去做kafka集群对接。 1.yml配置 2.消息发送 发送完毕后会在服务器中的topic下看到你传入的那个topic，并且会有三个分区，每个分区分别对应三台服务器并且每台服务器中会有两条消 ...
分类：
编程语言 时间：
2019-08-26 09:25:26
阅读次数：
220
本文主要以一些简单的小例子，简述在SpringMVC开发过程中，经常用到的Request方面的内容，仅供学习分享使用，如有不足之处，还请指正。 ...
分类：
编程语言 时间：
2019-08-25 01:11:35
阅读次数：
104
订阅发布模式 [TOC] 1、交换器（Exchange） 在 背后，其实是 把每条任务消息只发给一个消费者。本篇中我们将要研究如何把一条消息推送给多个消费者，这种模式被称为 （发布/订阅） ![订阅发布模式][1] 的消息发送模型核心思想是生产者不直接把消息发送到消息队列中。事实上，生产者不知道自己 ...
分类：
其他好文 时间：
2019-08-21 21:43:57
阅读次数：
91
转自 ： https://www.xncoding.com/2017/05/13/mq/rabbitmq-tutorial04.html Direct exchange也支持同一条消息发送到多个队列中： 同时还能支持交换机使用同一个binding key来和多个队列绑定， 这时候如果某个消息的rou ...
分类：
其他好文 时间：
2019-08-13 13:51:17
阅读次数：
105
AWSCloudWatch概念基于确定的内容监控基础设施组件基于指定的指标发送通知并触发各种操作分布式统计数据和收集系统，用于收集并跟踪指标默认情况下，在管理程序级别无缝收集指标，如CPU利用率、IO字节操作、网络字节操作CloudWatch可以触发包括启动终止重启EC2，增加减少AutoScaling组，将消息发送至SNS等操作属性面板（Dashboards）-可创建自定义面板来方便观察AWS环
分类：
其他好文 时间：
2019-08-08 10:29:56
阅读次数：
110
上一篇讲了消息发送确认，这一次来讲一讲 消息消费确认模式 消息发送确认，确认的是消息发送到交换机和队列的确认，消息消费确认则确认的是消息是否被消费者正常消费掉！ 消息的确认模式有三种 AcknowledgeMode.NONE：自动确认 AcknowledgeMode.AUTO：根据情况确认 Ackn ...
分类：
其他好文 时间：
2019-08-06 10:55:56
阅读次数：
87
RabbitMQ简介 RabbitMQ是一种消息队列，有着类似代理的作用，它允许软件、应用相互连接和扩展。这些应用可以相互链接起来组成一个更大的应用，或者将用户设备和数据进行连接，消息系统通过将消息的发送和接收分离来实现应用程序的异步和解偶。它可以为你的应用提供一个通用的消息发送和接收平台，并且保证 ...
分类：
其他好文 时间：
2019-08-05 18:52:55
阅读次数：
134
消息 1. 大多应用中，可通过消息服务中间件来提升系统异步通信、扩展解耦能力 2. 消息服务中两个重要概念： 消息代理（message broker）和目的地（destination） 当消息发送者发送消息以后，将由消息代理接管，消息代理保证消息传递到指定目 的地。 3. 消息队列主要有两种形式的目 ...
分类：
编程语言 时间：
2019-07-31 00:49:32
阅读次数：
94
一. 理解IPV6的组播地址 IPv6的 组播地址通常是为IPv6的组播服务，而IPv6通信的核心大量的使用了组播，IPv6不再使用广播，这与IPv4的通信不同，然而要理解IPv6的组 播， 首先需要明白三个关键点： 第一、任何节点都能够成为一个多播组成员也叫做组播组成员； 第二、源节点可以发送数据 ...
分类：
其他好文 时间：
2019-07-29 00:48:35
阅读次数：
125
python 发送kafka大体有三种方式 1 发送并忘记（不关注是否正常到达，不对返回结果做处理） 2 同步发送(通过get方法等待Kafka的响应，判断消息是否发送成功) 3 异步发送+回调函数(消息以异步的方式发送，通过回调函数返回消息发送成功/失败) 除此之外，还能发送压缩数据流 ...
分类：
编程语言 时间：
2019-07-23 17:06:13
阅读次数：
166
