当前位置：首页 > SEO技术 >

合肥如何搭建网站？现在流行的建站软件是什么？

96SEO 2026-02-19 17:00 0

证发送的消息可靠RabbitMQ的Confirm模式和2.Return模式

1、RabbitMQ消息Confirm模式保证从生产者到交换机的消息可靠1.1、Confirm模式简介1.2、具体代码实现1.2.1、application.yml

开启确认模式1.2.2、生产者方式1实现RabbitTemplate.ConfirmCallback生产者发送消息方式2直接写在生产者发送消息类实现RabbitTemplate.ConfirmCallback方式3匿名内部类写法方式4lambda表达式写法

1.2.3、RabbitConfig做交换机和队列的绑定1.2.4、pom.xml配置文件1.2.5、测试

2、RabbitMQ消息Return模式保证从交换机的到队列的消息可靠2.1、具体代码实现2.1.1、applicaton.yml2.1.2、pom.xml2.1.3、启动类2.1.4、业务层方式1实现RabbitTemplate.ReturnsCallback回调类MyReturnCallback配置类service业务层

方式2MessageService类实现RabbitTemplate.ReturnsCallback方式3匿名内部类实现RabbitTemplate.ReturnsCallback方式4lambda表达式实现RabbitTemplate.ReturnsCallback2.1.5、测试

1、RabbitMQ消息Confirm模式保证从生产者到交换机的消息可靠

1.1、Confirm模式简介

消息的confirm确认机制是指生产者投递消息后到达了消息服务器Broker里面的exchange交换机exchange交换机会给生产者一个应答生产者接收到应答用来确定这条消息是否正常的发送到Broker的exchange中这也是消息可靠性投递的重要保障。

1.2、具体代码实现

开启确认模式spring.rabbitmq.publisher-confirm-typecorrelated

写一个类实现RabbitTemplate.ConfirmCallback判断成功和失败的ack结果可以根据具体的结果如果ack为false对消息进行重新发送或记录日志等处理

rabbitTemplate.setConfirmCallback(messageConfirmCallBack);1.2.1、application.yml

开启确认模式

#开启生产者的确认模式设置关联模式my:exchangeName:

方式1实现RabbitTemplate.ConfirmCallback

单独写一个类实现RabbitTemplate.ConfirmCallback

package

org.springframework.amqp.rabbit.connection.CorrelationData;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.stereotype.Component;Component

Slf4j

{if(ack){log.info(消息正确到达交换机);return;}//ack为false,消息没有到达交换机log.error(消息没有到达交换机原因是{},cause);}

}生产者发送消息

com.power.config.MyConfirmCallback;

import

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.rabbit.connection.CorrelationData;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

confirmCallback;PostConstruct//构造方法后执行相当于初始化作用public

void

init(){rabbitTemplate.setConfirmCallback(confirmCallback);}Beanpublic

void

world.getBytes()).build();CorrelationData

correlationData

CorrelationData();//关联数据correlationData.setId(order_123456);//发送订单信息rabbitTemplate.convertAndSend(exchange.confirm.01,info,message,correlationData);log.info(消息发送完毕发送时间是{},new

Date());}

}方式2直接写在生产者发送消息类实现RabbitTemplate.ConfirmCallback

package

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.rabbit.connection.CorrelationData;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

rabbitTemplate;PostConstruct//构造方法后执行相当于初始化作用public

void

init(){rabbitTemplate.setConfirmCallback(this);}Beanpublic

void

world.getBytes()).build();CorrelationData

correlationData

void

{if(ack){log.info(消息正确到达交换机);return;}//ack为false,消息没有到达交换机log.error(消息没有到达交换机原因是{},cause);}

}方式3匿名内部类写法

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.rabbit.connection.CorrelationData;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

rabbitTemplate;PostConstruct//构造方法后执行相当于初始化作用public

void

init(){rabbitTemplate.setConfirmCallback(new

RabbitTemplate.ConfirmCallback()

{Overridepublic

{if(ack){log.info(消息正确到达交换机);return;}//ack为false,消息没有到达交换机log.error(消息没有到达交换机原因是{},cause);}});}Beanpublic

void

world.getBytes()).build();CorrelationData

correlationData

package

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.rabbit.connection.CorrelationData;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

rabbitTemplate;PostConstruct//构造方法后执行相当于初始化作用public

void

init(){rabbitTemplate.setConfirmCallback(//lambda表达式写法(correlationData,

ack,

cause)-{log.info(关联id{},correlationData.getId());if(ack){log.info(消息正确到达交换机);return;}//ack为false,消息没有到达交换机log.error(消息没有到达交换机原因是{},cause);});}Beanpublic

void

world.getBytes()).build();CorrelationData

correlationData

CorrelationData();//关联数据correlationData.setId(order_123456);//发送订单信息rabbitTemplate.convertAndSend(exchange.confirm.03,info,message,correlationData);log.info(消息发送完毕发送时间是{},new

Date());}}1.2.3、RabbitConfig做交换机和队列的绑定

package

org.springframework.amqp.core.*;

import

org.springframework.beans.factory.annotation.Value;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;Configuration

public

{Value(${my.exchangeName})private

String

exchangeName;Value(${my.queueName})private

String

ExchangeBuilder.directExchange(exchangeName).build();}//创建队列Beanpublic

Queue

QueueBuilder.durable(queueName).build();}//交换机绑定队列Beanpublic

Binding

BindingBuilder.bind(queueName).to(exchangeName).with(info);}

}1.2.4、pom.xml配置文件

xmlnshttp://maven.apache.org/POM/4.0.0

xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0

http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.power/groupIdartifactIdrabbit_08_confirm01/artifactIdversion1.0-SNAPSHOT/versionnamerabbit_08_confirm01/namepropertiesmaven.compiler.source8/maven.compiler.sourcemaven.compiler.target8/maven.compiler.targetproject.build.sourceEncodingUTF-8/project.build.sourceEncoding/propertiesparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.6.13/versionrelativePath//parentdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.24/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build/project1.2.5、测试

如果没有任何异常消息会正常发送到交换机

如果程序存在异常消息不会正常发送到交换机如果当交换机的名字不对时消息不会正常到底交换机的。

2、RabbitMQ消息Return模式保证从交换机的到队列的消息可靠

rabbitmq

使用rabbitTemplate.setConfirmCallback设置回调函数当消息发送到exchange后回调confirm方法。

在方法中判断ack如果为true则发送成功如果为false则发送失败需要处理

注意配置文件中开启

spring.rabbitmq.publisher-returns:

true使用rabbitTemplate.setReturnCallback设置退回函数当消息从exchange路由到queue失败后则会将消息退回给producer并执行回调函数returnedMessage

2.1、具体代码实现

xmlnshttp://maven.apache.org/POM/4.0.0

xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0

http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.power/groupIdartifactIdrabbit_09_return01/artifactIdversion1.0-SNAPSHOT/versionnamerabbit_09_return01/namepropertiesmaven.compiler.source8/maven.compiler.sourcemaven.compiler.target8/maven.compiler.targetproject.build.sourceEncodingUTF-8/project.build.sourceEncoding/propertiesparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.6.13/versionrelativePath//parentdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.24/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/plugin/plugins/build/project2.1.3、启动类

package

com.power.service.MessageService;

import

org.springframework.boot.ApplicationArguments;

import

org.springframework.boot.ApplicationRunner;

import

org.springframework.boot.SpringApplication;

import

org.springframework.boot.autoconfigure.SpringBootApplication;import

javax.annotation.Resource;SpringBootApplication

public

{SpringApplication.run(Application.class);}Overridepublic

void

方式1实现RabbitTemplate.ReturnsCallback

回调类MyReturnCallback

org.springframework.amqp.core.ReturnedMessage;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.stereotype.Component;/***

外部类*

returnedMessage(ReturnedMessage

returnedMessage)

{log.error(消息从交换机没有正确的投递到队列原因是{},returnedMessage.getReplyText());}

}配置类

org.springframework.amqp.core.*;

import

org.springframework.beans.factory.annotation.Value;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;Configuration

public

{Value(${my.exchangeName})private

String

exchangeName;Value(${my.queueName})private

String

ExchangeBuilder.directExchange(exchangeName).build();}//创建队列Beanpublic

Queue

QueueBuilder.durable(queueName).build();}//交换机绑定队列Beanpublic

Binding

BindingBuilder.bind(queue).to(directExchange).with(info);}

}service业务层

com.power.config.MyReturnCallback;

import

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

myReturnCallback;PostConstructpublic

void

init(){rabbitTemplate.setReturnsCallback(myReturnCallback);//设置回调}Beanpublic

void

world.getBytes()).build();rabbitTemplate.convertAndSend(exchange.return.01,info111,message);log.info(消息发送完毕发送时间是{},new

Date());}

}方式2MessageService类实现RabbitTemplate.ReturnsCallback

package

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.core.ReturnedMessage;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

rabbitTemplate;PostConstructpublic

void

init(){rabbitTemplate.setReturnsCallback(this);//设置回调}Beanpublic

void

world.getBytes()).build();rabbitTemplate.convertAndSend(exchange.return.01,info111,message);log.info(消息发送完毕发送时间是{},new

void

returnedMessage(ReturnedMessage

returnedMessage)

{log.error(消息从交换机没有正确的投递到队列原因是{},returnedMessage.getReplyText());}

}方式3匿名内部类实现RabbitTemplate.ReturnsCallback

package

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.core.ReturnedMessage;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

rabbitTemplate;PostConstructpublic

void

init(){rabbitTemplate.setReturnsCallback(new

RabbitTemplate.ReturnsCallback()

{Overridepublic

returnedMessage(ReturnedMessage

returned)

{log.error(消息从交换机没有正确的投递到队列原因是{},returned.getReplyText());}});}Beanpublic

void

world.getBytes()).build();rabbitTemplate.convertAndSend(exchange.return.01,info111,message);log.info(消息发送完毕发送时间是{},new

Date());}}核心代码

方式4lambda表达式实现RabbitTemplate.ReturnsCallback

package

org.springframework.amqp.core.Message;

import

org.springframework.amqp.core.MessageBuilder;

import

org.springframework.amqp.rabbit.core.RabbitTemplate;

import

org.springframework.context.annotation.Bean;

import

org.springframework.stereotype.Service;import

javax.annotation.PostConstruct;

import

rabbitTemplate;PostConstructpublic

void

init(){rabbitTemplate.setReturnsCallback(returned-

{log.error(消息从交换机没有正确的投递到队列原因是{},returned.getReplyText());});}Beanpublic

void

world.getBytes()).build();rabbitTemplate.convertAndSend(exchange.return.04,info111,message);log.info(消息发送完毕发送时间是{},new

Date());}}核心

标签： 新闻类网站排版网站建设 yasee119最新域名是什么现在的网站是用什么软件做的

上一篇：如何将WordPress编辑器切换回经典界面？
下一篇：如何高效阅读《代码大全2》并从中获益？

为您推荐

SEO优化服务概述

作为专业的SEO优化服务提供商，我们致力于通过科学、系统的搜索引擎优化策略，帮助企业在百度、Google等搜索引擎中获得更高的排名和流量。我们的服务涵盖网站结构优化、内容优化、技术SEO和链接建设等多个维度。

百度官方合作伙伴白帽SEO技术数据驱动优化效果长期稳定

SEO优化核心服务

网站技术SEO

网站结构优化 - 提升网站爬虫可访问性
页面速度优化 - 缩短加载时间，提高用户体验
移动端适配 - 确保移动设备友好性
HTTPS安全协议 - 提升网站安全性与信任度
结构化数据标记 - 增强搜索结果显示效果

内容优化服务

关键词研究与布局 - 精准定位目标关键词
高质量内容创作 - 原创、专业、有价值的内容
Meta标签优化 - 提升点击率和相关性
内容更新策略 - 保持网站内容新鲜度
多媒体内容优化 - 图片、视频SEO优化

外链建设策略

高质量外链获取 - 权威网站链接建设
品牌提及监控 - 追踪品牌在线曝光
行业目录提交 - 提升网站基础权威
社交媒体整合 - 增强内容传播力
链接质量分析 - 避免低质量链接风险

SEO服务方案对比

服务项目	基础套餐	标准套餐	高级定制
关键词优化数量	10-20个核心词	30-50个核心词+长尾词	80-150个全方位覆盖
内容优化	基础页面优化	全站内容优化+每月5篇原创	个性化内容策略+每月15篇原创
技术SEO	基本技术检查	全面技术优化+移动适配	深度技术重构+性能优化
外链建设	每月5-10条	每月20-30条高质量外链	每月50+条多渠道外链
数据报告	月度基础报告	双周详细报告+分析	每周深度报告+策略调整
效果保障	3-6个月见效	2-4个月见效	1-3个月快速见效

SEO优化实施流程

我们的SEO优化服务遵循科学严谨的流程，确保每一步都基于数据分析和行业最佳实践：

网站诊断分析

全面检测网站技术问题、内容质量、竞争对手情况，制定个性化优化方案。

关键词策略制定

基于用户搜索意图和商业目标，制定全面的关键词矩阵和布局策略。

技术优化实施

解决网站技术问题，优化网站结构，提升页面速度和移动端体验。

内容优化建设

创作高质量原创内容，优化现有页面，建立内容更新机制。

外链建设推广

获取高质量外部链接，建立品牌在线影响力，提升网站权威度。

数据监控调整

持续监控排名、流量和转化数据，根据效果调整优化策略。

SEO优化常见问题

SEO优化一般需要多长时间才能看到效果？

SEO是一个渐进的过程，通常需要3-6个月才能看到明显效果。具体时间取决于网站现状、竞争程度和优化强度。我们的标准套餐一般在2-4个月内开始显现效果，高级定制方案可能在1-3个月内就能看到初步成果。

你们使用白帽SEO技术还是黑帽技术？

我们始终坚持使用白帽SEO技术，遵循搜索引擎的官方指南。我们的优化策略注重长期效果和可持续性，绝不使用任何可能导致网站被惩罚的违规手段。作为百度官方合作伙伴，我们承诺提供安全、合规的SEO服务。

SEO优化后效果能持续多久？

通过我们的白帽SEO策略获得的排名和流量具有长期稳定性。一旦网站达到理想排名，只需适当的维护和更新，效果可以持续数年。我们提供优化后维护服务，确保您的网站长期保持竞争优势。

你们提供SEO优化效果保障吗？

我们提供基于数据的SEO效果承诺。根据服务套餐不同，我们承诺在约定时间内将核心关键词优化到指定排名位置，或实现约定的自然流量增长目标。所有承诺都会在服务合同中明确约定，并提供详细的KPI衡量标准。

SEO优化效果数据

基于我们服务的客户数据统计，平均优化效果如下：

+85%

自然搜索流量提升

+120%

关键词排名数量

+60%

网站转化率提升

3-6月

平均见效周期

行业案例 - 制造业

优化前：日均自然流量120，核心词无排名
优化6个月后：日均自然流量950，15个核心词首页排名
效果提升：流量增长692%，询盘量增加320%

行业案例 - 电商

优化前：月均自然订单50单，转化率1.2%
优化4个月后：月均自然订单210单，转化率2.8%
效果提升：订单增长320%，转化率提升133%

行业案例 - 教育

优化前：月均咨询量35个，主要依赖付费广告
优化5个月后：月均咨询量180个，自然流量占比65%
效果提升：咨询量增长414%，营销成本降低57%

为什么选择我们的SEO服务

专业团队

10年以上SEO经验专家带队
百度、Google认证工程师
内容创作、技术开发、数据分析多领域团队
持续培训保持技术领先

数据驱动

自主研发SEO分析工具
实时排名监控系统
竞争对手深度分析
效果可视化报告

透明合作

清晰的服务内容和价格
定期进展汇报和沟通
效果数据实时可查
灵活的合同条款

我们的SEO服务理念

我们坚信，真正的SEO优化不仅仅是追求排名，而是通过提供优质内容、优化用户体验、建立网站权威，最终实现可持续的业务增长。我们的目标是与客户建立长期合作关系，共同成长。