发送和接收分别是: 发送端bolt:outputcollector.emit(new Values(bytes)); 接收端bolt:byte[] message=input.getBinary(0): 其中bytes和message是大小一样的byte[]类型,字节数组。
采用getBinarybyFields()也不对,每次提交拓扑到集群,接收到的byte数组还不一样。
收起
报告相同问题?