spring集成netty实现rabbitmq的rpc通信

使用rabbitmq更多的是为了解耦，而有时候为了确保消息的落地我们需要在接收方处理完消息后，发送ack给发送方，以下使用spring-boot集成rabbitmq，netty来做这一点

如果你使用这种方式发送到接收方

//超时时间
rabbitTemplate.setReplyTimeout(20000);
final String resultMessages = (String) rabbitTemplate.convertSendAndReceive(mqexchange, mqroutekey, msg4send);
RPCFleetResult rpcFleetResult = jacksonMapper.readValue(resultMessages, RPCFleetResult.class);

在接收方使用

@Component
public class GPSDataListener extends MessageListenerAdapter
{
@Override
public void onMessage(Message message, Channel channel) {
super.handleResult(jacksonMapper.writeValueAsString(results),message,channel);
}
}

jacksonMapper.writeValueAsString(results) 以json字符串来传递对象,同样在发送端有相应的来解析json串封装成类,(保证两端的类是相同的)