bobboydog 2017-05-04 08:26
浏览 920

storm里tuple设置成byte[]字节数组,接收和发送的不一样

发送和接收分别是:
发送端bolt:outputcollector.emit(new Values(bytes));
接收端bolt:byte[] message=input.getBinary(0):
其中bytes和message是大小一样的byte[]类型,字节数组。

采用getBinarybyFields()也不对,每次提交拓扑到集群,接收到的byte数组还不一样。

  • 写回答

0条回答 默认 最新

    报告相同问题?