springboot整合了netty，将handler交与spring容器管理，在自定义的handler中使用了Service，企图使用依赖注入对应的组件，启动程序后发现注入为null，找了很多资料，最后得出结论；netty中使用的handler不是springboot容器创建的handler，故netty使用的handler无法自动注入service，如图，启动项目后这个Servic...

jackson是一个比较常用的json转换工具,功能很强大,本文为其基本方法的demo,实现的功能如题package commonsTest;import java.io.IOException;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.ut

    kfaka发消息的模式分为同步和异步,默认是同步的,异步的吞吐量比较高,但是消息丢失的概率比较大,同步还是异步可以通过producer.type属性进行控制    kafka有三种消息确认机制,由request.required.acks属性控制,acks=0时代表不适用确认机制,producer发送消息之后就不管消息是否成功,这种情况吞吐量最高,同时消息可靠性难以保证,会出现丢消息的问题

使用 wurstmeister 下的zookeeper 与kafkadocker pull wurstmeister/kafkadocker pull wurstmeister/zookeeper 然后使用启动两个容器docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeperdocker ...

Kafka系统架构Kafka介绍Kafka是一种高吞吐量的分布式发布订阅消息系统，有如下特性：通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以海量的消息存储也能够保持长时间的稳定性能(高性能)；高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息(高并发)；支持通过Kafka服务器和消费机集群来分区消息(高可靠)；支持Hadoop并行数据加载；支持各种语言丰富的客户端