NETCORE - CAP的使用 CAP 同时支持使用 RabbitMQ,Kafka,Azure Service Bus 等进行底层之间的消息发送。 CAP 目前支持使用 Sql Server,MySql,PostgreSql,MongoDB 数据库的项目。 安装部署RabbbitMQ:https: ...
分类:
Web程序 时间:
2020-05-23 20:19:57
阅读次数:
85
1.ActiveMQ重试机制是什么? 消费者收到消息,之后出现异常了,没有告诉broker确认收到该消息,broker会尝试再将该消息发送给消费者。尝试n次,如果消费者还是没有确认收到该消息,那么该消息将被放到死信队列中,之后broker不会再将该消息发送给消费者。 2.具体哪些情况会引发消息重发? ...
分类:
其他好文 时间:
2020-05-21 22:27:53
阅读次数:
145
二、读者写者问题 —个数据文件或记录可被多个进程共享,我们把只要求读该文件的进程称为“Reader 进程”,其他进程则称为“Writer进程”。允许多个进程同时读一个共享对象,因为读操 作不会使数据文件混乱。但不允许一个Writer进程和其他Reader进程或Writer进程同时访 问共享对象。因为 ...
分类:
系统相关 时间:
2020-05-21 14:37:23
阅读次数:
52
/** * 获取用户的openid * * @param int $uid 用户id * * @return mixed|string * * @throws ServiceException */public static function getOpenId(int $uid){ if (!$u ...
分类:
微信 时间:
2020-05-18 20:25:30
阅读次数:
135
Producer异步发送演示在上文中介绍了AdminClientAPI的使用,现在我们已经知道如何在应用中通过API去管理Kafka了。但在大多应用开发中,我们最常面临的场景就是发送消息到Kafka,或者从Kafka中消费消息,也就是典型的生产/消费模式。而本文将要演示的就是如何使用ProducerAPI将消息发送至Kafka中,使应用成为一个生产者。ProducerAPI具有以下几种发送模式:异
上一篇,讲了RabbitMQ的具体用法,可以看看这篇文章:RabbitMQ学习系列(三): C# 如何使用 RabbitMQ。今天说些理论的东西,Exchange 的几种模式。 AMQP协议中的核心思想就是生产者和消费者隔离,生产者从不直接将消息发送给队列。生产者通常不知道是否一个消息会被发送到队列 ...
分类:
其他好文 时间:
2020-05-09 17:12:38
阅读次数:
76
投递主要针对生产端,什么是生产端的可靠性投递? 保障消息成功的发出去 保证MQ节点成功收到消息 发送端收到MQ的确认应答 完善的消息补偿机制,只做前三步的时候,也许生产端就失败了 BAT/TMD 互联网大厂解决方案,看具体业务和并发量 消息落库,对消息状态进行打标 消息的延迟投递,做二次检查,回调检 ...
分类:
其他好文 时间:
2020-05-08 18:12:25
阅读次数:
101
解决将消息发送与消息处理进行了解耦,他同时支持异步和同步来发送和监听消息. .NET Core 使用MediatR CQRS模式 前言 CQRS(Command Query Responsibility Segregation)命令查询职责分离模式,它主要从我们业务系统中进行分离出我们(Comman ...
分类:
其他好文 时间:
2020-05-06 11:56:57
阅读次数:
59
1 概述 magic_chat目标是一款类似微信的即时通信软件,其后端是Python代码 Django框架实现的,功能包括注册、登录、消息发送、消息查看、实时发送消息等。 相关代码已上传github:https://github.com/djldjl/magic_chat 本文是后端服务的API接口 ...
企业微信设置 目录 企业微信设置... 1 一、前言... 1 二、在企业微信后台配置企业应用,并获得... 2 三、开通企业微信的通讯录同步功能... 4 四、将AppId及密钥配置到注册文件... 5 五、同步组织机构及人员... 5 六、消息发送... 6 一、前言 力软敏捷开发框架中能通过企 ...
分类:
微信 时间:
2020-05-01 13:05:18
阅读次数:
315