code: public void add(StreamFragmentBean streamFragmentBean) {
          buffer.add(streamFragmentBean);
          addCount++;
          LOG.info(new JSONObject() {{
              put("type", "stream");
              put("streamId", streamFragmentBean.getHeader().getId());
              put("description", "已收到 ---------------->    " + addCount * StreamManager.BUF_SIZE_IN_BYTE / (/*1024 * */1024d) + " kb");
              put("header", streamFragmentBean.getHeader());
          }});
      }
docs: 由于使用的是默认无界队列，因此写入是不阻塞的