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