通道 Coroutine\Channel 使用本地内存,不同的进程之间内存是隔离的。 只能在同一进程的不同协程内进行 push 和 pop 操作。 Co::set(['hook_flags'=> SWOOLE_HOOK_ALL]); Co\run(function(){ // 设置一个容量为1的通道 ...
分类:
其他好文 时间:
2020-07-12 19:10:33
阅读次数:
108
DjangoRestFramework开发实践 在这之前我写过一篇关于Django与Drf快速开发实践的博客,Django快速开发实践:Drf框架和xadmin配置指北,粗略说了一下Drf配置和基本使用,不过里面只是涉及到最基本的CRUD,在正常的后端开发中涉及的诸如认证和权限、消息队列、缓存之类的 ...
分类:
其他好文 时间:
2020-07-11 22:47:55
阅读次数:
56
什么是消息队列? 就是生产者生产一条消息,发送到这个rabbitmq,消费者连接rabbitmq并且进行消费,生产者和消费者并需要知道对方是如何工作的,从而实现程序之间的解耦,异步和削峰,这也就是消息队列的作用。 使用的场景也有很多,比如用户支付购买之后的发送短信,增加用户积分等等,只要能将业务逻辑 ...
分类:
其他好文 时间:
2020-07-11 19:12:08
阅读次数:
80
1 kafka介绍 Kafka是一款性能非常好的并且支持分布式的消息队列中间件由于它的高吞吐特性,Kafka通常使用在大数据领域,如日志收集平台Kafka是一个流处理平台,因为它在工作中就像是一个可以支撑高吞吐量的管道,数据像水一样流进去,然后另外一端再去读取这些数据我们就可以把Kafka看作是一种 ...
分类:
其他好文 时间:
2020-07-11 13:02:34
阅读次数:
55
一、简介 RabbitMQ是一套开源(MPL)的消息队列服务软件,是由LShift提供的一个Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的Erlang写成。所有主要的编程语言均有与代理接口通讯的客户端库。RabbitM ...
分类:
其他好文 时间:
2020-07-10 17:05:52
阅读次数:
71
网上看的大部分都是是说 配置 SimpleMessageListenerContainer 的 concurrentConsumers属性来确定activeMQ有多少个消费者。 但是: 我用的是 spring boot SimpleMessageListenerContainer 是自动配置的,并不 ...
分类:
编程语言 时间:
2020-07-10 15:31:42
阅读次数:
93
还是结合实际项目说把,最近在做跟保险公司和第三方借贷平台对接的项目; 其中需要第三方借贷平台借款并和保险挂对勾,也就是每次借钱的时候可以做一次保; 这里面正常情况下的逻辑场景: 借贷平台:借贷审核通过-->接收信息-->保险审核通过-->下发钱款通知APP执行出单; APP:出单{保单创建-->保单 ...
分类:
编程语言 时间:
2020-07-10 15:26:10
阅读次数:
95
前言 RabbitMQ?”“Kafka?”“RocketMQ?”...在日常学习与开发过程中,我们常常听到消息队列这个关键词。我也在我的多篇文章中提到了这个概念。可能你是熟练使用消息队列的老手,又或者你是不懂消息队列的新手,不论你了不了解消息队列,本文都将带你搞懂消息队列的一些基本理论。如果你是老手 ...
分类:
其他好文 时间:
2020-07-09 00:56:32
阅读次数:
124
图灵学院 java架构师学习路线 概述 ActiveMQ有支持两种事务, JMS transactions - the commit() / rollback() methods on a Session (which is like doing commit() / rollback() on a ...
分类:
其他好文 时间:
2020-07-08 14:56:33
阅读次数:
72
SpringBoot与消息 消息概述 大多应用中,可通过消息服务中间件来提升系统异步通信、扩展解耦能力 消息服务中两个重要概念: ? 消息代理(message broker)和目的地(destination) 当消息发送者发送消息以后,将由消息代理接管,消息代理保证消息传递到指定目的地。 消息队列主 ...
分类:
编程语言 时间:
2020-07-08 01:32:01
阅读次数:
82