网络协议 在学习时我们一般使用的就是tcp网络协议,BIO效率低 而主要用的也是NIO 而怎样用NIO呢 在acticemq.xml配置中增加nio 生产者消费者修改协议代码 nio增强 也是先配置然后改协议的顺序 去官网找到相关配置复制粘贴进去 注意端口然后修改协议61608 ActiveMQ的消 ...
分类:
其他好文 时间:
2020-07-06 14:28:22
阅读次数:
54
MQ主要流程 解耦,异步,消峰 其中目的地主要为队列或者主题 队列点对点 消息的生产者 或者 这时消息的生产者名字已经出来 并且入队的数量变成了3 上述完成的也就是这部分 消息的消费者 前四步大同小异 这里需要和消息发送者的类型一致,所以需要强转一下 其中等待接收可以设置为一直等或者设置时长 最后再 ...
分类:
其他好文 时间:
2020-07-06 12:33:08
阅读次数:
64
MDM全写Master Data Management,翻译为主数据管理或元数据管理。 什么是MDM 企业主数据是用来描述企业核心业务实体的数据,比如客户、合作伙伴、员工、产品、物料单、账户等;它是具有高业务价值的、可以在企业内跨越各个业务部门被重复使用的数据,并且存在于多个异构的应用系统中。 主数 ...
分类:
其他好文 时间:
2020-07-06 10:38:05
阅读次数:
114
1、工作队列现在的程序只定义有一个生产者和一个消费者,如果说现在有一个生产者对应多个消费者呢?那就表示一个工作队列,而工作队列的最大特征在于:若干个消费者一起完成工作。 当启动了多个消费者之后,这些消费者会一起共同完成所发出的消息消费处理,这样的处理可以保证消息处理的速度更加的快速。但是千万要记住, ...
分类:
其他好文 时间:
2020-07-05 17:06:38
阅读次数:
63
# RabbitMQ 实战教程 ## 1.MQ引言 ### 1.1 什么是MQ `MQ`(Message Quene) : 翻译为 `消息队列`,通过典型的 `生产者`和`消费者`模型,生产者不断向消息队列中生产消息,消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的,而且只关心消息的发送 ...
分类:
其他好文 时间:
2020-07-05 15:39:22
阅读次数:
63
消息驱动-Stream概述
消息驱动之生产者
消息驱动之消费者 ...
分类:
编程语言 时间:
2020-07-05 13:16:36
阅读次数:
76
消息丢失的场景 如果Kafka Producer使用“发后即忘”的方式发送消息,即调用producer.send(msg)方法来发送消息,方法会立即返回,但此时并不能说明消息已经发送成功。消息发送方式详见初次邂逅Kafka生产者。 如果在消息过程中发生了网络抖动,那么消息就会丢失;或发送的消息本身不 ...
分类:
其他好文 时间:
2020-07-03 19:33:54
阅读次数:
55
摘要:弹性负载均衡(Elastic Load Balance 简称ELB)将访问流量均衡分发到多台弹性云服务器,扩展应用系统对外的服务能力,实现更高水平的应用程序容错性能。 如今,随着互联网规模和消费者规模的不断扩大,企业面对着高并发请求场景下的流量冲击,尤其是每逢618或双11,会有数以亿计的用户 ...
分类:
其他好文 时间:
2020-07-03 15:56:11
阅读次数:
87
前言RabbitMQ是基于AMQP协议(Advanced Message Queue Protocol)的消息中间件 什么是消息队列 消息队列属于进程间通信的一种方式,使用消息队列可以通过异步方式处理数据,借此可以提高系统性能。我们可以把消息当作存放数据的容器,消息的消费者可以从队列中获取数据,进行 ...
分类:
其他好文 时间:
2020-07-03 00:37:23
阅读次数:
87
单例模式 Python中的单例模式的几种实现方式的及优化 装饰器 消费者模式 描述器 with原理与用法 python并发 Python并发编程理论篇 ...
分类:
编程语言 时间:
2020-07-01 23:40:35
阅读次数:
87