创建好这个文件之后，就可以去命令行项目根目录中执行docker-compose up，docker engine就会把上面配置的这4个组件全部启动起来。
注意：在启动完之后，需要去Kafka容器中创建一个名为CAR_NUMBER的topic，去Redis容器中创建一个名为counter的计数器(设置值为100，代表库存初始值为100)，去MySQL容器中创建一个名为seckill的数据表(包含一个自增长的id自段和一个timestamp格式的date字段)。
代码片段
1 . Seckill Service
第1-8行，引入了程序需要用到的对象，nodejs的mvc框架express, redis, kafka等
第10行，利用express提供的方法暴露出一个path为/seckill的POST方法
第12行，定义了一个方法，在54行会调用
第13-22行，新建了一个redis client并且监听error事件
第23行，这行代码非常关键，它的作用是让redis cilent监视redis中的counter值，之后会启动一个事务，如果在事务提交的时候发现有其它client修改了counter值的话，就会放弃这个事务。
第24行，通过redis client的异步方法获取counter的值，因为redis的get操作是原子的，所以在这里不用担心有并发读写的问题。
第25-28行，判断返回的库存值是否大于0，如果大于0，通过client.multi()启动一个事务，通过decr()方法将counter值减1，最后通过exec()方法提交事务；如果小于0，则执行第47行，打印卖完了并且关闭redis client。
第29-46行，这里我们看一下multi.exec()中的这个回调方法。在前面我们已经使用watch对counter进行了监视。如果在事务提交过程中有其它client修改了counter值的话，回调方法中的replies参数就会是null，可以看到第29-31行，程序会打印“可能有冲突”并且再次调用fn方法重试。
如果replies的值不为null，就会使用kafka的producer发送一条message到CAR_NUMBER topic。
2 . seckill_kafka_consumer
这里的代码就比较简单了，会初始化一个kafka consumer监听CAR_NUMBER topic，对于新获取的消息会去MySQL的seckill表里插入一条记录。
操作步骤
启动docker container
启动Seckill_Service
启动seckill_kafka_consumer
启动JMeter发送2000个并发请求
结果 JMeter request results 
Redis counter field
MySQL seckill table
可以看到，最后redis中的counter变成0，seckill数据表中会插入100条记录，没有发生超卖或者少卖的情况。当然在实际生产环境场景中，还有许多其它需要考虑的地方，希望此文可以起到一个抛砖引玉的作用，帮助大家更好的理解秒杀场景。
