rabbitmq异步处理_怎么解决js异步方法执行顺序

rabbitmq异步处理_怎么解决js异步方法执行顺序RabbitMQ即一个消息队列,主要是用来实现应用程序的异步和解耦,同时也能起到消息缓冲,消息分发的作用。使用RabbitMQ实现异步更新文章浏览量,提升阅读文章时的响应速度。从直接更新数据库耗时450ms到异步更新数据库耗时50ms,明显提升接口性能,非常的nice~………

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

使用RabbitMQ异步执行业务

1.导入依赖

<!-- 引入RabbitMq依赖 -->
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2.编写RabbitMQ配置文件

# rabbitmq配置
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=root
spring.rabbitmq.password=root
spring.rabbitmq.virtual-host=/handsomeforum
# 手动指定ack
spring.rabbitmq.listener.simple.acknowledge-mode=manual
# 开启confirm机制
spring.rabbitmq.publisher-confirm-type=simple
# 开启return机制
spring.rabbitmq.publisher-returns=true

3.编写RabbitMQ配置类

package com.handsome.rabbitmq;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/** * @Author Handsome * @Date 2022/7/4 10:12 * @Version 1.0 */
@SuppressWarnings({ 
   "all"})
	@Configuration
	public class RabbitMQConfig { 
   
	// 1.创建交换机
	@Bean
		public TopicExchange getTopicExchange() { 
   
		return new TopicExchange("handsomeforum-topic-exchange", true, false);
	}

	// 2.创建队列
	@Bean
		public Queue getQueue() { 
   
		return new Queue("handsomeforum-queue", true, false, false, null);
	}

	// 3.将交换机和队列绑定在一起
	@Bean
		public Binding getBinding() { 
   
		return BindingBuilder.bind(getQueue()).to(getTopicExchange()).with("handsomeforum.*");
	}

}

4.设置Return和Confirm机制

package com.handsome.rabbitmq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/** * @Author Handsome * @Date 2022/7/4 12:11 * @Version 1.0 */
@SuppressWarnings({ 
   "all"})
@Component
@Slf4j
public class PublisherConfirmAndReturnConfig implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback { 
   
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @PostConstruct
    private void initMethod() { 
   
        rabbitTemplate.setConfirmCallback(this);
        rabbitTemplate.setReturnCallback(this);
    }

    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) { 
   
        if (ack) { 
   
            log.info("消息已经送到Exchange中~");
        } else { 
   
            log.error("消息没有送到Exchange中~");
        }
    }

    @Override
    public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) { 
   
        log.error("消息没有送到Queue中~");
    }
}

5.将消息发送到交换机

// 发消息给mq异步更新文章浏览量
Map mqMap = new HashMap<>();
mqMap.put("bid", bid);
rabbitTemplate.convertAndSend("handsomeforum-topic-exchange",
"handsomeforum.readblog",
JSONObject.toJSONString(mqMap));

6.消费者消费消息

package com.handsome.rabbitmq;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.handsome.pojo.Blog;
import com.handsome.pojo.Question;
import com.handsome.pojo.UserLogin;
import com.handsome.service.BlogService;
import com.handsome.service.QuestionService;
import com.handsome.service.UserLoginService;
import com.handsome.service.VerifyMailboxService;
import com.handsome.utils.HandsomeUtils;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.mail.javamail.JavaMailSenderImpl;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;
import javax.mail.internet.MimeMessage;
import java.io.IOException;
/** * @Author Handsome * @Date 2022/7/4 10:24 * @Version 1.0 */
@SuppressWarnings({ 
"all"})
@Component
@Slf4j
public class Consumer { 

// 配置文件中取值
@Value(value = "${handsome.myMailbox}")
private String myMailbox;
@Autowired
JavaMailSenderImpl mailSender;
@Autowired
VerifyMailboxService verifyMailboxService;
@Autowired
UserLoginService userLoginService;
@Autowired
BlogService blogService;
@Autowired
QuestionService questionService;
// 自动ack
// @RabbitListener(queues = "handsomeforum-queue")
// public void getMessage(Object message) { 

// System.out.println("接收到的消息->" + message);
// }
@RabbitListener(queues = "handsomeforum-queue")
public void getMessage(@Payload String msg, Channel channel, Message message) throws IOException { 

// 1.获取routingKey
String routingKey = message.getMessageProperties().getReceivedRoutingKey();
// 2.使用switch
switch (routingKey) { 

// 更新文章浏览量
case "handsomeforum.readblog":
JSONObject readblogObject = JSON.parseObject(msg);
String bid = (String) readblogObject.get("bid");
Blog blog = blogService.getOne(new QueryWrapper<Blog>().eq("bid", bid));
blog.setViews(blog.getViews() + 1);
// todo: redis缓存. 防止阅读重复
blogService.updateById(blog);
// 手动ack channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
break;
}
}
}

7.RabbitMQ的作用

RabbitMQ即一个消息队列,主要是用来实现应用程序的异步和解耦,同时也能起到消息缓冲,消息分发的作用。
使用RabbitMQ实现异步更新文章浏览量,提升阅读文章时的响应速度。从直接更新数据库耗时450ms到异步更新数据库耗时50ms,明显提升接口性能,非常的nice~

RabbitMq忘记用户名和密码怎么办?

1.启动RabbitMq容器

rabbitmq异步处理_怎么解决js异步方法执行顺序

2.进入RabbitMq容器

rabbitmq异步处理_怎么解决js异步方法执行顺序

3.创建账号

rabbitmq异步处理_怎么解决js异步方法执行顺序

rabbitmqctl add_user newadmin newpassword

4.设置用户角色

rabbitmq异步处理_怎么解决js异步方法执行顺序

rabbitmqctl set_user_tags newadmin administrator

5.设置用户权限

rabbitmq异步处理_怎么解决js异步方法执行顺序

rabbitmqctl set_permissions -p / newadmin "." "." ".*"

6.newadmin为新管理员账号 newpassword为密码 进行登录

rabbitmq异步处理_怎么解决js异步方法执行顺序

7.登录成功

rabbitmq异步处理_怎么解决js异步方法执行顺序

8.找回原用户名

rabbitmq异步处理_怎么解决js异步方法执行顺序

9.更新root用户密码

rabbitmq异步处理_怎么解决js异步方法执行顺序

10.用root用户登录

rabbitmq异步处理_怎么解决js异步方法执行顺序

11.删除newadmin用户

rabbitmq异步处理_怎么解决js异步方法执行顺序

12.成功找回root用户,非常非常的nice~

我的学习论坛

HandsomeForum:用Java编写的学习论坛,打造我们自己的圈子!(http://huangjunjie.vip:66)
文章链接(使用RabbitMQ异步执行业务):http://huangjunjie.vip:66/blog/read/66incxp18s5nfhqgwt
文章链接(RabbitMq忘记用户名和密码怎么办?):http://huangjunjie.vip:66/question/read/0y4jzhrj5ipdu86wd1

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/186143.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 【金融科技前沿】【长文】金融监管、监管科技以及银行业监管报送概述「建议收藏」

    【金融科技前沿】【长文】金融监管、监管科技以及银行业监管报送概述「建议收藏」上周金融科技前沿课程的主题是《监管科技》,韩海燕老师从金融监管引入,介绍了我国的金融监管体系,接着进入监管科技的详细讲解。我觉得最主要的是弄清楚监管科技的定义,以及在实际的银行业应用场景中具体的运作流程是怎么样的。韩老师讲的很全面,将ABCD等金融科技手段在监管系统中是如何运作的讲的很清楚,收获颇丰,但是比较少涉及到监管的对象和内容,仍没有很清楚监管机构是要监管什么东西?监管机构要求银行金融业机构报送的资料有哪些?这些报送要求的目的分别是什么?所以这篇文章分为三个部分,一是介绍金融监管,二是介绍监科技,三.

  • 风口与泡沫中的寻路革命 —互联网医疗行业投资大数据

    风口与泡沫中的寻路革命 —互联网医疗行业投资大数据

  • 转:不同的行业和工作的真实情况是怎样的?「建议收藏」

    ————————————————————————————————————–不同的行业和工作的真实情况是怎样的?收入、发展前景和挑战如何?这个问题可能会耽误您很多时间,但是,这个问题实在是憋了许久。每个大学生考虑以后从事行业的方式都不同,这

  • IT培训行业揭秘(一)

    IT培训行业揭秘(一)前言:闲扯淡IT培训行业的各种你不知道的事情!

  • 2021-2027年中国视频监控设备行业市场需求预测与投资战略规划分析报告[通俗易懂]

    2021-2027年中国视频监控设备行业市场需求预测与投资战略规划分析报告[通俗易懂]【报告类型】产业研究【报告价格】4500起【出版时间】即时更新(交付时间约3个工作日)【发布机构】智研瞻产业研究院【报告格式】PDF版本报告介绍了中国视频监控设备行业市场行业相关概述、中国视频监控设备行业市场行业运行环境、分析了中国视频监控设备行业市场行业的现状、中国视频监控设备市场行业竞争格局、对中国视频监控设备行业市场行业做了重点企业经营状况分析及中国视频监控设备行业市场行业发展前景与投资预测。您若想对中国视频监控设备行业市场行业有个系统的了解或者想投资中国视频监控设备行业市场…

  • 网络安全未来发展前景_十四五国家网络安全规划

    网络安全未来发展前景_十四五国家网络安全规划第1章:中国网络安全行业发展综述1.1网络安全行业概述1.1.1网络安全产业的概念分析1.1.2网络安全产品和服务分类(1)依据主要功能及形态分类(2)依据安全防御生命周期技术能力分类1.2网络安全行业发展环境分析1.2.1行业政策环境分析(1)国际政策(2)国内政策1.2.2行业社会环境分析(1)境内感染网络病毒终端数(2)境内被篡改网站数量(3)境内被植入后门网站数量(4)安全漏洞数量1.2.3行业经济环境分析(1)国内生产总值分析(2)工业增加值分析.

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号