分布式鏈路跟蹤sleuth詳解5月8日老司機(jī)帶開(kāi)整合

1:SpringAMQP整合一:通過(guò)rabbitmqAdmin來(lái)交換機(jī)，隊(duì)列,綁 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}*隊(duì)publicQueuequeue001()returnnew}publicQueuequeue002()returnnew}publicQueuequeue003()returnnew}隊(duì)列二綁定到DirectExchangepublicBindingqueue002BindingDirectExchange()return}*DirectExchangepublicBindingqueue003BindingDirectExchange()return} 交換機(jī)綁定二個(gè)隊(duì)列(queue01queue001top.key.*publicBindingqueue001BindingTopicExchange002()return}*publicBindingqueue003BindingTopicExchange()return}queue001publicBindingqueue001BindingFanoutExchange()return}publicBindingqueue002BindingFanoutExchange001()returnpublicvoidtestRabbitTemteToDirecit()MessagePropertiesmessagePropertiesnewMessageProperties();rabbitTemte.convertAndSend("directExchange001","direct.key.key1",message);}publicvoidtestRabbitTemteToTopic()MessagePropertiesmessagePropertiesnewMessageProperties();Messagemessage=newMessage("測(cè)試rabbitmqTem{publicMessagepostProcessMessage(Messagemessage)throwsSystem.out.println("調(diào)用MessagePostProcessor處理消息");returnmessage;}}publicvoidtestRabbitTem}二:SimpleMessageListenerContrinerpublicSimpleMessageListenerContainersimpleMessageListenerContainer()SimpleMessageListenerContainermessageListenerContainer=new{publicStringcreateConsumerTag(Stringqueue)returnqueue+":"+queue.hashCode()+}{publicvoidonMessage(Messagemessage,Channelchannel)throwsSystem.out.println("消費(fèi)的消息:"+new}return}三.SimpleMessageListenerContainer通過(guò)設(shè)置messageAdapter來(lái)設(shè)置消息消費(fèi)者{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生產(chǎn)端開(kāi)啟確認(rèn)功能 {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("消費(fèi)端Payload

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