Redis订单MySQL存储一致性-redis订单id(8-15-41)

Redis本文目录一览：

• 1、一起讨论下,消息幂等(去重)通用解决方案
• 2、分布式系统中实现幂等性的几种方式
• 3、数据多的时候为什么要使用redis而不用mysql?
• 4、C#怎么使用redis实现秒杀功能
• 5、Redis发布订阅和Stream
• 6、面试官杠上重复消费、消息堆积、消息丢失、顺序消息?

一起讨论下,消息幂等(去重)通用解决方案

1、为了解决以上问题，就需要保证接口的幂等性 ，接口的幂等性实际上就是接口可重复调用，在调用方多次调用的情况下，接口最终得到的结果是一致的。

2、如果要保证一致性，需要生产者在失败后重试，不过重试又会导致消息重复的问题，一个解决方案是每个消息给一个唯一的id，通过服务端的主动去重来避免重复消息的问题，不过这一机制目前Kafka还未实现。

3、速度最快，但是无法找回数据。truncate （table）是删除表数据，不删除表的结构，速度排第二，但不能与where一起使用。delete from是删除表中的数据，不删除表结构，速度最慢，但可以与where连用，可以删除指定的行。

4、查询 查询的API，可以说是天然的幂等性，因为你查询一次和查询两次，对于系统来讲，没有任何数据的变更，所以，查询一次和查询多次一样的。

分布式系统中实现幂等性的几种方式

有些接口可以天然的实现幂等性 ，比如查询接口，对于查询来说，你查询一次和两次，对于系统来说，没有任何影响，查出的结果也是一样。除了查询功能具有天然的幂等性之外，增加、更新、删除都要保证幂等性。

总而言之，接口符合幂等性在可以降低系统实现的复杂性，并能保证资源状态的一致性。RESTFul风格的接口设计本质上使用的是HTTP协议的请求方法，因此，RESTFul接口方法的幂等性指的就是HTTP方法的幂等性。

数据的对象和范围 你要考虑你的幂等的全局性：空间全局性和时间全局性。空间全局性：比如是交易流水幂等还是用户ID幂等。

第四，最终一致性（Eventually Consistent）通过异步事件做到。 如果消息具有操作幂等性，也就是一个消息被应用多次与应用一次产生的效果是一样的话，那么把不需要同步执行的事务交给异步消息推送和订阅者集群来处理即可。

最终一致性 在工程实践上，为了保障系统的可用性，互联网系统大多将强一致性需求转换成最终一致性的需求，并通过系统执行幂等性的保证，保证数据的最终一致性。

查询 查询的API，可以说是天然的幂等性，因为你查询一次和查询两次，对于系统来讲，没有任何数据的变更，所以，查询一次和查询多次一样的。

数据多的时候为什么要使用redis而不用mysql?

通常来说，当数据多、并发量大的时候，架构中可以引入Redis，帮助提升架构的整体性能，减少Mysql（或其他数据库）的压力，但不是使用Redis，就不用MySQL。

redis可以作为存储的扩展部分，但是不能直接替换掉mysql。redis对事务的支持还是比较简单的。但是redis的性能和扩展性比较好，使用起来比较方便。不会的。只能是一种互补。

那么为什么要使用类似redis这样的Nosql数据库呢？1） 当数据量的总大小一个机器放不下时；2） 数据索引一个机器的内存放不下时；3） 访问量（读写混合）一个实例放不下时。

mysql读写分离只是减少了服务器的并发读写时候的压力。从而提高高并发或者大量数据读写时候的效率。redis做缓存，类似于hibernate的三级缓存，hibernate三级缓存是用ehcache实现的。

C#怎么使用redis实现秒杀功能

1、C是组合，与次序无关，A是排列，与次序有关；C的意思就是没有排列，组合到一起就行，与他们的次序没有关系；A的排列，就是有排列顺序。

2、网络用语中c是一个用来取缔一些不好的词汇的缩写，通常用来表达不适合在屏幕上或公共场合直接说出口的内容。

3、大写字母C，下标n，上标m，表示从n个元素中取出m 个元素的不同的方法数.如从5个人中选2人去开会，不同的选法有C（5，2）=10种。

4、C语言是一种计算机程序设计语言，同样的C++，Java，汇编等都是程序设计语言，但是各有各的有点，c语言有一下特点：C是高级语言。它把高级语言的基本结构和语句与低级语言的实用性结合起来。

5、c是字母符号。C（大写） 、c（小写）是英文字母顺数第三个，俄语字母顺数第19个。例如：英语单词cloud和“苏联”的俄语缩写СССР的第一个字母就是c。

6、数学符号c右上角是1右下角是4的意思是数学中的组合，右下角的4表示总体个数，右上角的1表示抽取个数，且从4个里面抽取一个，C=4÷1=4。

Redis发布订阅和Stream

发布订单系统是日常开发中经常会用到的功能。简单来说，就是发布者发布消息，订阅者就会接受到消息并进行相应的处理，如下图所示。Redis为我们提供了发布/订阅的功能模块PubSub，可以用于消息传递。

云数据库redis的应用场景有：缓存、会话存储、发布/订阅系统、计数器和排行榜、实时数据分析。缓存 Redis最常见的用途就是作为缓存层，由于Redis存储在内存中，读写速度非常快，可以显著减轻数据库或其他后端服务的负载压力。

使用XLEN命令来获取一个Stream的条目数量：按范围查询： XRANGE 和 XREVRANGE 要根据范围查询Stream，我们只需要提供两个ID，即start 和 end。返回的区间数据将会包括ID是start和end的元素，因此区间是完全包含的。

ActiveMQ，是消息中间件，存储模型队列（有序、优先级）等，数据可以刷到磁盘（一般都需要刷到磁盘）。

面试官杠上重复消费、消息堆积、消息丢失、顺序消息?

顺序消息是指消息的 消费顺序 和 产生顺序 相同，在有些业务逻辑下，必须保证顺序，比如订单的生成、付款、发货，这个消息必须按顺序处理才行。

消息是顺序的，先进先出原则，这个由Rabbitmq保证，不同队列中的消息顺序，是没有保证的，例如：进地铁站的时候，排了三个队伍，不同队伍之间的，不能确保谁先进站。

其实，上述3中情况导致消息丢失归根结底是因为RabbitMQ的自动ack机制，即默认RabbitMQ在消息发出后就立即将这条消息删除，而不管消费端是否接收到，是否处理完，导致消费端消息丢失时RabbitMQ自己又没有这条消息了。

消息不被及时回复很焦虑，可以采取以下措施：首先要正确认识自己的情绪，不要把没有得到正面反馈的事情当作负面反馈或对自己的否定。每个人都有自己的事要做，不及时回复或者不回复并不代表别人不重视你或者不喜欢你。

默认情况消费者收到消息，MQ就会从队列中删除消息，如果消费者没处理成功，消息就丢了，可以使用手动ACK机制，处理完成手动调用MQ的ACK方法通知MQ删除消息。

我们使用RocketMQ顺序消息来模拟一下订单的场景，顺序消息分为两部分：顺序发送、顺序消费。 顺序发消息 上面代码模拟了按顺序依次发送创建、支付、退款消息到TopicTest中。