当前位置： 首页 > news >正文

投注网站建设需要提升关键词排名有哪些方法

news 2026/4/7 11:16:30
投注网站建设需要,提升关键词排名有哪些方法,湛江企业模板建站,专业网站建设公司首选公司需求分析 本案例是通过一个发送短信验证码的功能来实验MQ发送消息时实现分布式事务，思路分析如下 消息生产者生产发送验证码的半消息 生产者执行本地事务（将验证码保存到数据库），并记录事务的ID，如果整个过程不出现异…

在这里插入图片描述

需求分析

本案例是通过一个发送短信验证码的功能来实验MQ发送消息时实现分布式事务，思路分析如下

  • 消息生产者生产发送验证码的半消息

  • 生产者执行本地事务（将验证码保存到数据库），并记录事务的ID，如果整个过程不出现异常，则提交事务，消息成功投递，否则进行事务的回滚操作

  • MQ二次确认消息是否成功投递，如果没成功（发生了异常），则丢弃消息

需求实现

一、创建项目

  • 创建一个主工程（stream-mq-demo），目的是维护项目的版本号、一些必要的类库、集成SpringCloudAlibaba
  • 子工程（producer），目的是生产发送验证码的消息，及使用事务将验证码保存到数据库
  • 子工程（consumer），目的是消费消息

二、主工程

2.1、pom.xml

目的是维护项目的版本号、一些必要的类库、以及集成SpringCloudAlibaba

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.1.5.RELEASE</version></parent><groupId>org.example</groupId><artifactId>stream-mq-demo</artifactId><packaging>pom</packaging><version>1.0-SNAPSHOT</version><modules><module>producer</module><module>consumer</module></modules><properties><spring-cloud.version>Greenwich.SR1</spring-cloud.version><spring-cloud-alibaba.version>0.9.0.RELEASE</spring-cloud-alibaba.version><java.version>1.8</java.version><lombok.version>1.18.8</lombok.version><rocketmq.version>2.0.3</rocketmq.version><mybatis.plus.version>3.5.1</mybatis.plus.version><mysql.version>8.0.32</mysql.version></properties><dependencies><!-- RocketMQ坐标 --><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>${rocketmq.version}</version></dependency><!-- SpringCloudStream坐标 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-stream-rocketmq</artifactId></dependency><!-- SpringWeb坐标 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- lombok坐标 --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version></dependency><!-- test --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><dependencyManagement><dependencies><!--整合spring cloud--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><!--整合spring cloud alibaba--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>${spring-cloud-alibaba.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>
</project>

三、Producer子工程

3.1、pom.xml

添加MyBatisPlus、MySQL、FastJSON类库

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><parent><artifactId>stream-mq-demo</artifactId><groupId>org.example</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>producer</artifactId><dependencies><!-- mybatis-plus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>${mybatis.plus.version}</version></dependency><!-- mysql-connector --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><!-- fastjson --><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>2.0.12</version></dependency></dependencies>
</project>

3.2、application.yml

  • 配置数据源（application_druid.yml）
  • 配置端口号为8081
  • 配置MQ的name-server地址
  • 配置SpringCloudStream的消费者模式并开启事务
  • 配置MQ的topic

数据源application_druid.yml

spring:datasource:type: com.zaxxer.hikari.HikariDataSourcedriver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://192.168.0.3:3306/mq_demo?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=trueusername: rootpassword: Aa123123.jackson:date-format: yyyy-MM-dd HH:mm:ss
mybatis-plus:type-aliases-package: demo.entityconfiguration:log-impl: org.apache.ibatis.logging.stdout.StdOutImplglobal-config:db-config:table-prefix: t_

主配置文件application.yml

spring:profiles:include: druidcloud:stream:rocketmq:binder:name-server: 192.168.0.3:9876bindings:#消费者output:producer:#事务消息transactional: true#与AddBonusTransactionListener类中@RocketMQTransactionListener一致group: tx-captcha-groupbindings:output:#用来指定topic，要和content-center微服务的topic匹配destination: captcha-topic
server:port: 8081

3.3、启动类

使用@EnableBinding(Source.class)定义消息的推送管道

Source.class源代码

public interface Source {String OUTPUT = "output";@Output("output")MessageChannel output();
}

application.yml中配置的output属性

在这里插入图片描述

启动类

package demo;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;@SpringBootApplication
@EnableBinding(Source.class)
public class ProducerApplication {public static void main(String[] args) {SpringApplication.run(ProducerApplication.class, args);}
}

3.4、必要的实体类

验证码类

package demo.entity;import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import lombok.Builder;
import lombok.Data;import java.util.Date;@Data
@Builder
public class Captcha {@JsonSerialize(using = ToStringSerializer.class)@TableId(type = IdType.AUTO)private Integer id;private String captcha;private String phone;private Date publishTime;
}

事务日志类

package demo.entity;import lombok.Builder;
import lombok.Data;import java.util.Date;@Data
@Builder
public class TransactionLog {private String transactionId;private Date createTime;private String log;
}

3.5、本地事务类

  • 发送半消息
  • 保存验证码到数据库并记录日志
package demo.service;import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import demo.entity.Captcha;
import demo.entity.TransactionLog;
import demo.mapper.CaptchaMapper;
import demo.mapper.TransactionLogMapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.support.RocketMQHeaders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;@Slf4j
@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class SendCaptchaService {private final Source source;private final TransactionLogMapper transactionLogMapper;private final CaptchaMapper boundMapper;/** 发送半消息*/public void sendCaptchaMsg(Captcha captcha){// 发送半消息。。String transactionId = UUID.randomUUID().toString();Map<String, Object> msg = new HashMap<>();msg.put("phone", captcha.getPhone());msg.put("captcha", captcha.getCaptcha());this.source.output().send(MessageBuilder.withPayload(msg)// header也有妙用....setHeader(RocketMQHeaders.TRANSACTION_ID, transactionId).setHeader("dto", JSON.toJSONString(captcha)).build());}/**添加验证码到数据库，并记录事务日志*/@Transactional(rollbackFor = Exception.class)public void addBoundWithRocketMqLog(Captcha captcha, String transactionId) {//执行本地事务this.addBound(captcha);//记录MQ事务日志transactionLogMapper.insert(TransactionLog.builder().transactionId(transactionId).createTime(new Date()).log("发送短信验证码").build());}/**将验证码保存到数据库*/@Transactional(rollbackFor = Exception.class)public void addBound(Captcha captcha){captcha.setPublishTime(new Date());boundMapper.insert(captcha);}
}

3.6、MQ事务类

MQ事务类实现RocketMQLocalTransactionListener接口

  • 重写用于执行本地事务的方法executeLocalTransaction，在该方法中执行本地事务类的保存验证码到数据库并记录日志的方法addBoundWithRocketMqLog
  • 重写本地事务的检查接口，检查本地事务是否执行成功，即：MQ没有收到执行本地事务后的二次确认checkLocalTransaction，在该方法中去查询事务日志表（t_transaction_log）是否存在相同事务ID的日志，如果不存在则将消息丢弃，否则标记为成功投递
package demo.mq;import com.alibaba.fastjson.JSON;
import demo.entity.Captcha;
import demo.entity.TransactionLog;
import demo.mapper.TransactionLogMapper;
import demo.service.SendCaptchaService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionListener;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
import org.apache.rocketmq.spring.support.RocketMQHeaders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;@RocketMQTransactionListener(txProducerGroup = "tx-captcha-group")
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
@Slf4j
public class SendCaptchaTransactionListener implements RocketMQLocalTransactionListener {private final SendCaptchaService addBoundService;private final TransactionLogMapper transactionLogMapper;/** 用于执行本地事务的方法*/@Overridepublic RocketMQLocalTransactionState executeLocalTransaction(Message msg, Object arg) {MessageHeaders headers = msg.getHeaders();String transactionId = (String) headers.get(RocketMQHeaders.TRANSACTION_ID);String dtoString = (String) headers.get("dto");Captcha bound = JSON.parseObject(dtoString, Captcha.class);//本地事务（service层用@Transaction标注的方法）成功就提交，本地事务失败就回滚try {//执行本地事务addBoundService.addBoundWithRocketMqLog(bound, transactionId);return RocketMQLocalTransactionState.COMMIT; //本地事务执行成功就提交MQ} catch (Exception e) {return RocketMQLocalTransactionState.ROLLBACK; //本地事务执行失败就回滚MQ}}/** 本地事务的检查接口，检查本地事务是否执行成功，即：MQ没有收到执行本地事务后的二次确认*/@Overridepublic RocketMQLocalTransactionState checkLocalTransaction(Message msg) {MessageHeaders headers = msg.getHeaders();String transactionId = (String) headers.get(RocketMQHeaders.TRANSACTION_ID);log.info("MQ二次事务检查，transactionID={}", transactionId);// 从MQ事务日志表里查，看看对应的事务ID是否存在记录，如果存在则表示成功（COMMIT)，否则表示执行本地事务失败(ROLLBACK)TransactionLog transactionLog = transactionLogMapper.selectById(transactionId);if (transactionLog != null) {return RocketMQLocalTransactionState.COMMIT;} else {return RocketMQLocalTransactionState.ROLLBACK;}}
}

3.7、测试

使用单元测试，创建测试方法调用本地事务类发送半消息

package demo;import demo.entity.Captcha;
import demo.service.SendCaptchaService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;@SpringBootTest(classes = {ProducerApplication.class})
@RunWith(SpringJUnit4ClassRunner.class)
public class TestSendCaptcha {@Autowiredprivate SendCaptchaService sendCaptchaMsg;@Testpublic void test(){//随机生成一个4位的验证码String code = "";for(int i=0; i<4; i++){code += (int)(Math.random()*10);}//发送半消息sendCaptchaMsg.sendCaptchaMsg(Captcha.builder().captcha(code).phone("13843188848").build());}
}

运行单元测试方法之后浏览器访问MQ-Dashboard可以看到topic已经被创建

在这里插入图片描述

在Message中可以看到刚刚发送的消息

在这里插入图片描述

消息详情

在这里插入图片描述

数据库验证码表（t_captcha）插入了数据

数据库事务日志表（t_transaction_log）插入了数据

在这里插入图片描述

Tip：可以在本地事务中模拟一个运行时异常，可以发现事务日志表中并无法插入日志，在MQ事务二次确认消息的时候会讲消息丢弃

四、Consumer子工程

4.1、application.yml

  • 配置端口号为8082
  • 配置MQ的name-server地址
  • 配置MQ的topic
  • 配置group，如果使用的消息队列是RocketMQ，则该属性务必配置，内容可以是任意字符串
spring:cloud:stream:rocketmq:binder:name-server: 192.168.0.3:9876bindings:#消息消费者input:#用来指定topic，要和消息生产者的的topic匹配destination: captcha-topic#一定要设置，必填项，如果用其他MQ，该属性可以不设置group: test
server:port: 8082

4.2、启动类

  • 使用@EnableBinding(Sink.class)定义消息的推送管道

Sink.class源代码

public interface Sink {String INPUT = "input";@Input("input")SubscribableChannel input();
}

application.yml中配置的input属性

在这里插入图片描述

  • 使用@StreamListener(Sink.INPUT)注解监听消息
  • 使用@StreamListener(“errorChannel”)统一处理MQ的异常

启动类

package demo;import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.ErrorMessage;import java.util.HashMap;@Slf4j
@SpringBootApplication
@EnableBinding(Sink.class)
public class ConsumerApplication {/*** 消费消息监听器** @param message*/@StreamListener(Sink.INPUT)public void receive(HashMap<String, Object> message) {log.info("消费消息={}", message);}/*** 全局异常处理** @param message 发生异常的消息*/@StreamListener("errorChannel")public void error(Message<?> message) {ErrorMessage errorMessage = (ErrorMessage) message;log.warn("RocketMQ-SpringCloudStream发生异常，errorMessage={}", errorMessage);}public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class, args);}
}

4.3、测试

再次执行Producer子工程单元测试方法发送半消息，发现在Consumer子工程中成功监听到了消息

在这里插入图片描述

4.4、消息过滤器

​ 在@StreamListener注解中可以使用condition属性来定义要匹配（过滤）的消息，将消费者改造一下，只接收手机号为13843188848的消息

Tip：该方式只支持RoketMQ，不支持Kafka/RabbitMQ

		/*** 消费消息监听器** condition的作用是消息过滤，当前案例是匹配消息中header属性phone的值为13843188848的消息*/@StreamListener(value = Sink.INPUT, condition = "headers['phone']=='13843188848'")public void receive(HashMap<String, Object> message) {log.info("消费消息={}", message);}

如果不满足匹配条件将会有提示

在这里插入图片描述

但是消息已经成功发送

在这里插入图片描述

http://www.hkea.cn/news/801802/

相关文章：

  • 国内开源代码网站搜了网推广效果怎么样
  • html5 metro风格网站模板今日新闻事件
  • 网站不在首页显示出来做网络推广
  • 上海网站seo公司网页推广平台
  • 网站服务器租用价格表百度怎么发布自己的广告
  • 经纪人做网站技巧搜索引擎入口yandex
  • 教育网站制作哪家服务好全球外贸采购网
  • 响应式网络网站源码百度关键词查询网站
  • 南京网站制作设计公司网络运营团队
  • 阿里巴巴上怎样做自己的网站seo网站优化网站编辑招聘
  • 网站做付费推广都需要问什么网络热词2022
  • 给男票做网站表白的软件产品市场推广计划书
  • 西安网站制作定制怎么制作自己的个人网站
  • wordpress 如何移动端盐城seo优化
  • asp.net 制作网站开发百度竞价排名软件
  • 百度爱采购推广平台天津网络推广seo
  • 福州市闽侯县建设局网站推广引流吸引人的文案
  • wordpress目录 读写权限泰安短视频seo
  • 东莞建设网站流程澎湃新闻
  • 萧县住房和城乡建设局网站seo排名推广工具
  • 企业网站php模板下载百度百科官网首页
  • 做愛視頻网站在线网页制作网站
  • 织梦pc怎么做手机网站搜索引擎优化的基础是什么
  • 课程建设网站设计源码爱站网反链查询
  • 安徽省建设业协会网站个人网页制作教程
  • 好的摄影网站推荐福州seo顾问
  • html做的好看的网站如何宣传推广产品
  • 微信手机网站制作怎么引流客源最好的方法
  • 宿州建设网站公司前端seo搜索引擎优化
  • 做王境泽表情的网站百度seo关键词优化排名