/** * RabbitMQ消息确认机制 * 关于rabbit的生产和消费方的一些实用的操作; * producer的confirm和consumer的ack,这两者使用的模式都是用来保证数据完整性,防止数据丢失 */ /** * producer的confirm模式 * 业务场景描述: * 促销系 ...
分类:
其他好文 时间:
2020-02-14 11:14:24
阅读次数:
98
题目内容 Given a singly linked list, determine if it is a palindrome. Example: 分析过程 题目归类: 链表反转,fast/slow双指针法 题目分析: 这道题归到easy其实是不对的,应该归到medium,因为如果要考虑O(n)时 ...
分类:
其他好文 时间:
2020-02-13 15:00:47
阅读次数:
64
函数式接口就是只定义一个抽象方法的接口。在java8中,接口还可以拥有默认方法(即在类没有对方法进行实现时,其主体为方法提供默认实现的方法)。哪怕有很多默认方法,只要接口只定义了一个抽象方法,它就依然是一个函数式接口。 函数式接口带有@FunctionalInterface的标注,但它不是必须的。如 ...
分类:
其他好文 时间:
2020-02-11 15:59:35
阅读次数:
64
1. elementAt() temp.elementAt(0) 返回temp这个vector里面存放的第一个元素 也是一个vector类型。 2. 字符串空格分割 3. ==与equals ==比较引用,equals比较值 4. 删除字符串最后一个汉字 5. String与string java中 ...
分类:
编程语言 时间:
2020-02-11 00:26:43
阅读次数:
88
1 import aiohttp 2 import asyncio 3 4 def consumer(): 5 r='' 6 while True: 7 n = yield r 8 if n: 9 r='200 OK' 10 print('客户取走了%s'%(str(n))) 11 else: 12 ...
分类:
编程语言 时间:
2020-02-10 00:14:11
阅读次数:
95
Dec 16, 2019 ~ Dec 22, 2019 Algorithm Problem 53 Maximum Subarray 最大子数组 "题目链接" 题目描述:给定一个数组,在所有连续的子数组中,求得其中的最大值,举例如下: 数组:[ 2,1, 3,4, 1,2,1, 5,4] 返回结果:6 ...
分类:
其他好文 时间:
2020-02-09 20:29:38
阅读次数:
53
"offset" "topic" "consumer group" "consumer" "producer" "producer golang" topic 工具 "https://cwiki.apache.org/confluence/display/KAFKA/Replication+tool ...
分类:
其他好文 时间:
2020-02-09 18:42:32
阅读次数:
243
增加了buffsize,生产者生产过多,wait #include <stdio.h> #include <unistd.h> #include <pthread.h> #define PRODUCER_SIZE 1 #define CONSUMER_SIZE 1 int products = 0; ...
分类:
其他好文 时间:
2020-02-09 16:28:51
阅读次数:
66
JDK提供了大量常用的函数式接口以丰富Lambda的典型使用场景,它们主要在 java.util.function 包中被提供。 下面是最简单的Consumer接口及使用示例。 Consumer接口概述 @FunctionalInterface public interface Consumer<T ...
分类:
编程语言 时间:
2020-02-09 09:57:22
阅读次数:
70
I have a simple RabbitMQ test program randomly enqueuing messages, and another reading them, all using Spring-AMQP. If the consumer dies (for example ...
分类:
其他好文 时间:
2020-02-08 11:51:37
阅读次数:
113