WebApiResult为封装公用方法,不是微软自带,此段代码指是做画龙点睛作用,添加队列、异步消费等 public async Task AuthentDeal() { //从数据库查询要处理的队列 var batchList = _MySqlMasterDb.tab1.Where(p => p. ...
分类:
编程语言 时间:
2020-07-22 11:23:11
阅读次数:
156
Queue表示对象的先进先出集合。实现了ICollection接口,可以由数组或链表两种形式实现,在.NET中是以数组的形式实现的。 概念 队列是一种特殊的线性表,特殊之处在于它只允许在表头(head)进行删除操作,而在表尾(tail)进行插入操作。 队列的数据元素又称为队列元素。在队列中插入一个队 ...
分类:
其他好文 时间:
2020-07-21 22:22:47
阅读次数:
77
转自: https://blog.csdn.net/ID__9527/article/details/84255680 RocketMQ是阿里巴巴公司的一个消息队列框架(很多思想借鉴Kafka),对于RocketMQ本身不做过多说明,下面主要说明RocketMQ的两种消费模型。 消费模型有两种:广播 ...
分类:
其他好文 时间:
2020-07-21 21:27:30
阅读次数:
82
Promise 源码 https://github.com/lfp1024/promise promise-a-plus const PENDING = 'PENDING' const REJECTED = 'REJECTED' const RESOLVED = 'RESOLVED' const r ...
分类:
其他好文 时间:
2020-07-21 01:26:28
阅读次数:
102
排序逻辑 每一轮找出剩余队列中的最小值放在前面 初始队列 第一轮 第二轮 第三轮 代码示例 public static void selectSort(int[] arr){ for(int i=0; i<arr.length-1; i++){ int min = i; for(int j=i+1; ...
分类:
编程语言 时间:
2020-07-21 01:16:14
阅读次数:
60
一、下载第三方扩展pheanstalk composer require pda/pheanstalk 二、公共文件conn.php <?php /** * 公共连接脚本 */ include_once "vendor/autoload.php"; //$conn = \Pheanstalk\Phe ...
分类:
其他好文 时间:
2020-07-21 01:16:00
阅读次数:
81
排序逻辑 每次遍历,保证前面的队列是有序的 初始队列 第一轮 第二轮 第三轮 第四轮 代码示例 public static void insertSort(int[] arr){ //从第二个数开始遍历所有的数字,每一次遍历保证前面的序列是有序的 for(int i=1;i<arr.length;i ...
分类:
编程语言 时间:
2020-07-21 01:03:43
阅读次数:
61
思考: 1,消息丢失是什么造成的,从生产端和消费端两个角度来考虑? 2,消息重复是什么造成的,从生产端和消费端两个角度来考虑? 3,如何保证消息有序? 4,如果保证消息不重不漏,损失的是什么? 1.为什么会发生消息丢失和消息重复?消息发送Kafka消息发送有两种方式:同步(sync)和异步(asyn ...
分类:
其他好文 时间:
2020-07-21 00:57:57
阅读次数:
177
Queue(队列)接口 表示Collection的子接口,表示队列FIFO(First In First Out)先进先出 常用方法: ? 抛出异常: ? boolean add(E e) - 顺序添加一个元素(到达上限后,再添加则会抛出异常 ) ? E remove() - 获得第一个元素并移除( ...
分类:
其他好文 时间:
2020-07-20 22:36:41
阅读次数:
87
lc 剑指 Offer 09. 用两个栈实现队列 题目描述 输入输出描述 思路 1、使用传统的栈Stack即可完成 2、使用Deque数据结构堵住一端(堵住首) (addLast(),removeLast) 或者堵住尾(addFirst();removeFirst) 3、使用Deque数据结构堵住一 ...
分类:
其他好文 时间:
2020-07-20 13:02:17
阅读次数:
66