1.概述最近和一些同学交流的时候反馈说，在面试Kafka时，被问到Kafka组件组成部分、API使用、Consumer和Producer原理及作用等问题都能详细作答。但是，问到一个平时不注意的问题，就是Kafka的幂等性，被卡主了。那么，今天笔者就为大家来剖析一下Kafka的幂等性原理及实现。2.内容2.1Kafka为啥需要幂等性？Producer在生产发送消息时，难免会重复发送消息。Produc
分类：
其他好文 时间：
2019-12-13 23:49:36
阅读次数：
167
实际系统中有很多操作，是不管做多少次，都应该产生一样的效果或返回一样的结果。例如： 前端重复提交选中的数据，应该后台只产生对应这个数据的一个反应结果。 我们发起一笔付款请求，应该只扣用户账户一次钱，当遇到网络重发或系统bug重发，也应该只扣一次钱； 发送消息，也应该只发一次，同样的短信发给用户，用户 ...
分类：
其他好文 时间：
2019-12-13 09:31:41
阅读次数：
194
#!/usr/bin/perl use IPC::SysV qw(IPC_PRIVATE IPC_CREAT S_IRWXU); use IPC::Msg; my $queue = IPC::Msg->new(IPC_PRIVATE, S_IRWXU | IPC_CREAT); $msgtype = ...
分类：
其他好文 时间：
2019-12-10 13:02:06
阅读次数：
112
今天就来康康spring怎么整合RabbitMQ 注意一点，在发送消息的时候对template进行配置mandatory=true保证监听有效 生产端还可以配置其他属性，比如发送重试，超时时间、次数、间隔等 消费端核心配置 首先配置手工确认模式，用于ACK的手工处理，这样我们可以保证消息的可靠性送达 ...
分类：
编程语言 时间：
2019-12-09 21:18:57
阅读次数：
112
RocketMQ是我们常用的消息中间件，在运行单元测试时，我们可能不需要真正发送消息（除非是为了测试发送消息），也不想因为连结不上RocketMQ的Broker,NameServer而影响单元测试运行。 那我们该如何Mock RocketMQ消息生产者呢？ 请看例子： 1 2 3 4 5 6 7 8 ...
分类：
其他好文 时间：
2019-12-09 19:42:10
阅读次数：
100
一、hello/hi网络程序编程 1、服务端 1 sever.c 2 #include<stdio.h> 3 #include<Winsock2.h> 4 #include<time.h> 5 #include<string.h> 6 #pragma warning(disable:4996) 7 ...
分类：
编程语言 时间：
2019-12-08 12:27:24
阅读次数：
70
[toc] Kafka生产者端 可靠性保证： producer向broker发送消息数据，需要有一定的可靠性，至少要保证数据： 1、不丢失 2、不重复 producer提供了一些参数，在编写producer是进行合理设置和编写，就可以保证数据的可靠性。 acks 参数配置 为保证producer发送 ...
分类：
编程语言 时间：
2019-12-07 23:16:20
阅读次数：
165
[toc] bootstrap.servers broker集群地址，格式：ip1:port,ip2:port...，不需要设定全部的集群地址，设置两个或者两个以上即可。 group.id 消费者隶属的消费者组名称，如果为空会报异常，一般而言，这个参数要有一定的业务意义。 fetch.min.byt ...
分类：
其他好文 时间：
2019-12-07 16:41:02
阅读次数：
543
[toc] acks 这个参数用老指定分区中必须由多少个副本收到消息，之后生产者才会认为这条消息写入是成功的。acks参数有三种类型的值（都是字符串类型）。 acks=1 默认值为1.生产者发送消息之后，只要分区的leader副本成功的写入消息，生产端就会收到来自服务端的成功响应，说明发送成功。如果 ...
分类：
其他好文 时间：
2019-12-07 16:34:14
阅读次数：
268
实际系统中有很多操作，是不管做多少次，都应该产生一样的效果或返回一样的结果。例如：前端重复提交选中的数据，应该后台只产生对应这个数据的一个反应结果。我们发起一笔付款请求，应该只扣用户账户一次钱，当遇到网络重发或系统bug重发，也应该只扣一次钱；发送消息，也应该只发一次，同样的短信发给用户，用户会哭的；创建业务订单，一次业务请求只能创建一个，创建多个就会出大问题。等等很多重要的情况，这些逻辑都需要幂
分类：
其他好文 时间：
2019-12-06 21:57:42
阅读次数：
126
