分布式链路跟踪sleuth详解5月8日老司机带开整合

1:SpringAMQP整合一:通过rabbitmqAdmin来交换机，队列,绑 publicConnectionFactoryconnectionFactory()CachingConnectionFactorycachingConnectionFactory=newCachingConnectionFactory();return}{RabbitAdminrabbitAdmin=newRabbitAdmin(connectionFactory);return}publicvoidtestRabbitAdmin() //rabbitAdmin.declareBinding(newBinding("temp.queue.direct",Binding.DestinationType.QUEUE,"temp.direct","terabbitAdmin.declareBinding(newBinding("temp.queue.topic",Binding.DestinationType.QUEUE,"temp.topic","temrabbitAdmin.declareBinding(newBinding("temp.queue.fanout",Binding.DestinationType.QUEUE,"temp.fanout","}@parampublicRabbitTemterabbitTemte(ConnectionFactory{RabbitTemterabbitTemte=newRabbitTemte(connectionFactory);returnrabbitTemte;}publicDirectExchangedirectExchange()returnnew}publicTopicExchangetopicExchange()returnnew}publicFanoutExchangefanoutExchange()returnnew}*队publicQueuequeue001()returnnew}publicQueuequeue002()returnnew}publicQueuequeue003()returnnew}队列二绑定到DirectExchangepublicBindingqueue002BindingDirectExchange()return}*DirectExchangepublicBindingqueue003BindingDirectExchange()return} 交换机绑定二个队列(queue01queue001top.key.*publicBindingqueue001BindingTopicExchange002()return}*publicBindingqueue003BindingTopicExchange()return}queue001publicBindingqueue001BindingFanoutExchange()return}publicBindingqueue002BindingFanoutExchange001()returnpublicvoidtestRabbitTemteToDirecit()MessagePropertiesmessagePropertiesnewMessageProperties();rabbitTemte.convertAndSend("directExchange001","direct.key.key1",message);}publicvoidtestRabbitTemteToTopic()MessagePropertiesmessagePropertiesnewMessageProperties();Messagemessage=newMessage("测试rabbitmqTem{publicMessagepostProcessMessage(Messagemessage)throwsSystem.out.println("调用MessagePostProcessor处理消息");returnmessage;}}publicvoidtestRabbitTem}二:SimpleMessageListenerContrinerpublicSimpleMessageListenerContainersimpleMessageListenerContainer()SimpleMessageListenerContainermessageListenerContainer=new{publicStringcreateConsumerTag(Stringqueue)returnqueue+":"+queue.hashCode()+}{publicvoidonMessage(Messagemessage,Channelchannel)throwsSystem.out.println("消费的消息:"+new}return}三.SimpleMessageListenerContainer通过设置messageAdapter来设置消息消费者{SimpleMessageListenerContainermessageListenerContainer=newpublicStringcreateConsumerTag(Stringqueue)returnqueue+":"+queue.hashCode()+}MessageListenerAdaptermessageListenerAdapter=newMessageListenerAdapter(newreturnmessageListenerContainer;}publicclassMessageDelegatepublicvoidhandleMessage(byte[]bodys)}publicvoidhandleMessage(String} publicvoidconsumerMsg(byte[]bodys) publicvoidconsumerMsg(String{publicclassTextMessageConverterimplements{publicMessagetoMessage(Objectobject,MessagePropertiesmessageProperties)throwsMessageConversionExceptionreturnnewMessage(object.toString().getBytes(),messageProperties);}publicObjectfromMessage(Messagemessage)throws{if(message.getMessageProperties().getContentType().contains("text")){returnnewString(message.getBody());}return}}}spring.rabbitmq.publisher-confirms=true生产端开启确认功能 {rabbitTemte.setConfirmCallback(angleConfirmCallBack);rabbitTemte.setReturnCallback(angleReturnCallBack);Messagemessage=StringmsgId=UUID.randomUUID().toString();CorrelationDatacorrelationDatanewCorrelationData(msgId);}publicclassAngleConfirmCallBackimplementsRabbitTem{publicvoidconfirm(CorrelationDatacorrelationData,booleanack,String if(!ack)}}}publicclassAngleReturnCallBackimplementsRabbitTem{publicvoidreturnedMessage(Messagemessage,intreplyCode,StringreplyText,Stringexchange,String{System.out.println("message:"+message);}}}publicQueue{returnnew}publicQueue{returnnew}publicTopicExchange{returnnew}publicBindingbinding()return}publicBindingbinding2()return}}@RabbitListener(queues=publicvoidmsgConsumer(Messagemessage,Channelchannel)throwsLongdeliveryTag=(Long)message.getHeaders().get(AmqpHeaders.DELIVERY_TAG);}@RabbitListener(queues=publicvoidmsgConsumer2(@PayloadOrderorderChannelchannel@HeadersMap<String,Objectheaders)throwsILongdeliveryTag=(Long)headers.get(AmqpHeaders.DELIVERY_TAG);}}publicclassRabbitReceiver@RabbitListener(bindings=@QueueBinding(value=@Queue(value="queue-1",durable="true"),exchange=@Exchange(value="exchange-1",type="topic",key="springboot.*"))publicvoidonMessage(Messagemessage,Channelchannel)throws{System.err.println("消费端Payload

channel.basicAck(deliveryTagfalse);}*@param@param@param@throws@RabbitListener(bindings=value=@Queue(value="${}",exchange=@Exchange(value="