1、RabbitMqPublisher.cs （发送消息） 2、RabbitMqQuery.cs （队列消息拉取） 3、RabbitMqListener.cs （消息监听与推送） 4、RabbitMQ.Test（测试代码） ...
分类：
其他好文 时间：
2019-07-17 18:58:44
阅读次数：
109
在学习webflux 之前我们先要了解一个概念 什么是背压(back press) 对我们以前使用的发布订阅模式来说.我们的以前的模式是 消费只能通过提供者提供的数据来持续消费 如果一直发送消息,那么就只能一直消费 我们对背压做一个详细的比喻 比如我们每家每户,都有一个水龙头.自来水公司相当于发布者 ...
分类：
Web程序 时间：
2019-07-17 10:57:40
阅读次数：
178
锁是Java并发编程中最重要的同步机制。锁除了让临界区互斥执行外，还可以让释放锁的线程向获取同一个锁的线程发送消息。 锁的获取和释放 线程释放锁时，JMM会把该线程对应的本地内存中的共享变量刷新到主内存中。 线程获取锁时，JMM会把该线程对应的本地内存置为无效。从而使得被监视器保护的临界区代码必须从 ...
分类：
其他好文 时间：
2019-07-14 15:22:52
阅读次数：
113
创建一个2个分区，3个副本的topic，名字叫first kafka-topics.sh --create --zookeeper datanode1:2181 --partitions 2 --replication-factor 3 --topic first 生产者发送消息顺序发送： 消费者接 ...
分类：
其他好文 时间：
2019-07-14 15:06:31
阅读次数：
274
队列消息持久化之JDBC 1、 配置activemq.xml文件，修改持久化方式为jdbc 2、在broker外配置数据库连接bean 3、启动服务，可以看到数据库中多了3张表，表明配置成功 4、运行Producer，模拟生产者发送消息 控制台输出： Activemq管理控制台： 数据库表中: 5、 ...
分类：
其他好文 时间：
2019-07-11 12:20:40
阅读次数：
70
一、计算机网络参考模型 1、分层思想的意义 (1)是整个流程更加清晰话，复杂的问题简单化。 (2)更容易发现问题，针对性的解决问题 2、OSI参考模型（开放系统互连参考模型） 概述：由ISO(国际化标组织)与1984年颁布的OSI（开放系统互连）参考模型。 七层模型：由下到上 物理层、数据链路层、网 ...
分类：
其他好文 时间：
2019-07-11 09:15:43
阅读次数：
126
1 使用无连接的套接字，我们能够在自我包含的数据包里发送消息，采用独立的读函数读取消息，读取的消息是使用独立的发送函数发送的。但是UDP数据包不能保证可靠传输，存在许多的因素，比如网络繁忙等等，都有可能阻止数据包到达指定的目的地。 2 （1）UDP的简单应用： 3 由于UDP是一种无连接的协议。因此... ...
消息队列是典型的 生产者 消费者模型 ,生产者只管发送消息,消费者只管监听队列取出消息,没有业务逻辑的侵入,实现了生产者和消费者的 解耦 ,这篇博客主要从如下几个方面整理相关RabbitMQ的知识点 1. 消息中间件在项目中的使用场景 2. RabbitMQ常见的 五种消息模型 3. 如何 避免消息 ...
分类：
其他好文 时间：
2019-07-08 13:46:46
阅读次数：
60
谈谈分布式消息队列的一些特性，比较两种比较常用的消息队列——NSQ和Kafka 1 消息队列的作用 解耦，将一个流程加入一层数据接口拆分成两个部分，上游专注通知，下游专注处理 缓冲，应对流量的突然上涨变更，消息队列有很好的缓冲削峰作用 异步，上游发送消息以后可以马上返回，处理工作交给下游进行 广播， ...
分类：
其他好文 时间：
2019-07-07 17:46:07
阅读次数：
213
很多同学私信问我Kafka在性能优化方面做了哪些举措，对于相关问题的答案其实我早就写过了，就是没有系统的整理一篇，最近思考着花点时间来整理一下，下次再有同学问我相关的问题我就可以潇洒的甩个链接了。这个问题也是Kafka面试的时候的常见问题，面试官问你这个问题也不算刁难你。在网上也有很多相关的文章开讲 ...
分类：
其他好文 时间：
2019-07-03 10:39:42
阅读次数：
144
