1、zoie中需要自己继承StreamDataProvider<T>来实现自己系统中的一个数据提供的处理者 。 T为自己系统中需要处理的数据的泛型 。
2、StreamDataProvider自己并不会自动启动消费数据，继承类在实例化时候，需要给其注入消费者实例（一般为ZoieSystem），若不注入则无法消费数据 。
3、然后在系统的运行中需要线程定时 或者 其它方法去调用StreamDataProvider<T>的start()方法，然后其在start()中其中一个消费数据的线程（该线程持有StreamDataProvider的实例对象）。