讨论一下kafka参数的配置 1、acks 参数配置 acks这个参数有三个值：0，1，-1，但是不用的参数对应的含义不同，那如果我们想要保证数据不丢失，acks 值应该设置为哪个参数呢？ 0：代表生产者只要把消息发送出去以后就认为消息发送成功了，这种方式有可能会导致数据丢失，因为有可能消息发送到服 ...
分类：
其他好文 时间：
2020-06-14 18:20:10
阅读次数：
66
fanout 扇出 也曾为广播 在广播模式下，消息发送流程是这样的： 可以有多个消费者 每个消费者有自己的queue(队列) 每个队列都要绑定到Exchange(交换机) 生产者发送的消息，只能够发送到交换机，交换机决堤要发送给那个队列，生产者无法决定 交换机把消息发送给绑定过的所有队列 队列的消费 ...
分类：
其他好文 时间：
2020-06-06 21:22:38
阅读次数：
161
1.常见的我们是进入它的消费者模式 , 在里面输入 , 但是如何封装到shell中 kafka-console-producer.sh --broker-list node1:9092 --topic sky 比如我只想把 hello 这条消息发送到Topic sky里面 echo "hello" ...
分类：
系统相关 时间：
2020-06-03 23:08:22
阅读次数：
153
1.1.2 消息队列的两种模式 1）点对点模式（一对一，消费者主动拉取数据，消息收到后消息清除） 消息生产者生产消息发送到Queue中，然后消息消费者从Queue中取出并且消费消息。 消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费者，但 ...
分类：
其他好文 时间：
2020-06-03 00:41:04
阅读次数：
180
前言 首先，大家先了解一下三者的概念究竟是什么？有哪些功能？工作原理？ 一、RabbitMQ 1.消息型中间件，用于不同应用之间的通信，基于amqp协议实现 2.功能：将一些无需要及时返回而且耗时的操作提取出来，进行解耦，利用异步处理，提高系统的吞吐量 3工作原理：A生产消息，发送给服务器的exch ...
分类：
数据库 时间：
2020-05-29 17:53:48
阅读次数：
71
官网地址：https://www.rabbitmq.com/getstarted.html RabbitMQ 1.docker 安装 RabbitMQ docker pull rabbitmq:management //拉去rabbitmq管理版 //启动rabbitmq docker run -d ...
分类：
其他好文 时间：
2020-05-28 14:54:36
阅读次数：
40
HTML5是下一代的Web应用，它具有许多新的特性，是一种新兴的技术并且在移动应用中也有着广泛的使用。但也正是因为它的一些新特性的出现以及广泛的应用，使得其安全性非常值得关注。 在本文中，我们将针对HTML5 Web消息发送（跨域消息发送）的安全性进行分析和研究。 跨域消息发送 在讨论这一问题之前， ...
分类：
Web程序 时间：
2020-05-28 00:41:46
阅读次数：
73
一、简介 Redis 发布订阅(pub/sub)是一种 消息通信模式 ：发送者(pub)发送消息，订阅者(sub)接收消息。（比如：微信、 微博、关注系统！） Redis 客户端可以订阅任意数量的频道。 订阅/发布消息图： 第一个：消息发送者， 第二个：频道 第三个：消息订阅者！ 下图展示了频道 c ...
分类：
其他好文 时间：
2020-05-27 01:12:50
阅读次数：
66
应用场景由于朋友所在公司对安全性要求较高，zabbix所在的网络环境不能上外网，因此不能通过zabbix将告警直接发送至一些即时通讯工具，这就需要将报警消息发送至一些中间件，并通过中间件转发出去，这里选择使用了kafka，当然kafka中不只有报警信息，也有其他需要发送的数据，这里就不过多透漏基础环境配置kafka集群已部署好，这里不介绍安装细节vim/etc/hosts192.168.179.1
分类：
其他好文 时间：
2020-05-26 10:32:24
阅读次数：
118
cola扩展点使用和设计初探 封装变化，可灵活应对程序的需求变化。 扩展点使用 步骤: 定义扩展点接口，类型可以是校验器，转换器，实体； 必须以ExtPt结尾，表示一个扩展点。 比如，我定义一个云枢的组织结构的扩展点接口，消息发送扩展点，二开扩展点，webapi的rest接口扩展点点。 定义扩展点接 ...
分类：
其他好文 时间：
2020-05-26 01:17:41
阅读次数：
119
