使用kryoserialization。
实施 CustomObjectSerializer :

class CustomObjectSerializer extends Serializer<CustomObject> {  
  @Override
  public void write(final Kryo kryo,
                    final Output output,
                    final CustomObject cObject) {
    // do serialization
  }

  @Override
  public CustomObject read(final Kryo kryo,
                           final Input input,
                           final Class<CustomObject> aClass) {
    // do deserialization
  }
}

将customobjectserializer注册到storm配置： conf.registerSerialization(CustomObject.class,CustomObjectSerializer.class);

你可以简单地发出你的声音 List ,

collector.emit(new Values(listCustomObject));

当你在报纸上读到的时候 bolt 这样地，

List<CustomObject> listCustomObject = (List<CustomObject>) tuple.getValue(0);

希望有帮助。
编辑：事实上我忘了提到对象必须是 Serializable ! 为了处理这个列表，我会这样做：

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

public class CustomObjectList implements Serializable {

    private static final long serialVersionUID = 6877020084704724252L;

    public class CustomObject {
        ...
    }

    private final List<CustomObject> list = new ArrayList<>();

    ...
}

edit2：因为我背了太多的东西，所以我通过修改 ExclamationBolt 在storm starter exaclamationtopology中
看起来像这样。

package storm.starter;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import backtype.storm.task.OutputCollector;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.base.BaseRichBolt;
import backtype.storm.tuple.Fields;
import backtype.storm.tuple.Tuple;
import backtype.storm.tuple.Values;

public class ExclamationBolt extends BaseRichBolt{

    public static Logger LOG = LoggerFactory.getLogger(ExclamationBolt.class);    

    public class CustomObject {
        private String word;

        public CustomObject(String word) {
            setWord(word);
        }

        public String getWord() {
            return word;
        }

        public void setWord(String word) {
            this.word = word;
        }

    }
    public class CustomObjectList implements Serializable {

        private static final long serialVersionUID = 6877020084704724252L;

        private final List<CustomObject> list = new ArrayList<>();

        public CustomObjectList() {
        }

        public List<CustomObject> getObjects() {
            return list;
        }

        public void addObject(CustomObject o) {
            list.add(o);
        }
    }

    OutputCollector _collector;

    public ExclamationBolt() {
    }

    @Override
    public void prepare(Map conf, TopologyContext context, OutputCollector collector) {
        _collector = collector;
    }

    @Override
    public void execute(Tuple tuple) {
        String id = tuple.getSourceComponent();
        String word;
        if ("word".equals(id)) {
            word = tuple.getString(0);
        } else {
            CustomObjectList list = (CustomObjectList) tuple.getValue(0);
            word = list.getObjects().get(0).getWord();
        }
        word = word + "!!!";
        LOG.debug(word);
        CustomObjectList list = new CustomObjectList();
        list.addObject(new CustomObject(word));
        _collector.emit(tuple, new Values(list));
        _collector.ack(tuple);
    }

    @Override
    public void declareOutputFields(OutputFieldsDeclarer declarer) {
        declarer.declare(new Fields("word"));
    }

}

希望有帮助。