首页 > 其他分享 >大菜菜学习RabbitMQ——第二篇

大菜菜学习RabbitMQ——第二篇

时间:2024-04-08 18:56:43浏览次数:23  
标签:java com 菜菜 RabbitMQ host springframework org import 第二篇

我在上一节讲述了如何使用Rabbitmq图形化界面在我们学习这个的基础使用,然后我们现在就要做的就是用java进行rabbitmq操作

首先在黑马课上有一个mq-demo文件这个资料,各位可以去微信程序里面下载对应资料包,然后会在百度网盘里

链接:https://pan.baidu.com/s/1VFdBOQYZVACxUBkzBuLVHA
提取码:nefi

这个就是这个demo,是一个分布式微服务框架的文件,然后,我们放到我们idea里面以后就直接开始进行以下操作即可

我们在这个publish这个模块的这个application.yml里面添加对应的spring配置

logging:
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS
spring:
  rabbitmq:
    host: localhost
    port: 5672
    virtual-host: /hmall
    username: hmall
    password: 123

这些是整个文件对应的代码不需要删除(直接copy),当然这个是基于windows系统下,你的host是localhost,如果是虚拟机,填写主机地址,用户名和密码自己写自己的

然后我们就可以开始写java代码了,在这里我们写一个单元测试,在publisher目录下这个test文件里面创建一个com.itheima.publisher

然后就可以开始书写了,类名自己创建

package com.itheima.publisher;

import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * 功能:
 * 作者:LiCooer
 * 日期:2024/4/8 16:22
 */

@SpringBootTest
public class SpringAmqpTest {

    @Autowired
    private RabbitTemplate rabbitTemplate;


    @Test
    void testSendMessage2Queue() {
        String queueName = "simple.queue";
        String msg = "hello , amqp!";
        rabbitTemplate.convertAndSend(queueName , msg);
    }
}

这个就是我们对应的java代码,然后就可以单元测试运行

 如果出现了问题直接老方法,google,chatgpt,或者在评论写出自己的问题

 

 这样我们就可以看到了,至此,本文结束了,你在本篇文章需要确保学会了如果用java代码传递消息

标签:java,com,菜菜,RabbitMQ,host,springframework,org,import,第二篇
From: https://www.cnblogs.com/codeforceshobby/p/18122273

相关文章

  • 大菜菜学习RabbitMQ——第一篇
    现在开始呢我在学MQ,首先这篇博客,如果需要借鉴的话,前提是,你要有消息队列对应的前置知识,如果没有的话可以去B站或者去其他的博客上面学习不多逼逼,现在开始首先是localhost:15672,如果你下载好了rabbitmq,这个应该是很不陌生的,对于刚开始使用者来说就是guest,但是我们其实可以添加用户......
  • RabbitMQ经典知识
    消息可靠性投递消息的可靠性投递主要是保证消息投递的每一个环节都要成功RabbitMQ整个消息投递路径为Producer-》Broker-》Exchange-》Queue-》Consumer生产者到交换机Producer发送到Exchange的过程依靠RabbitMQ的Confirm机制来确保可靠性生产者投递消息到了Broker里的Exc......
  • Kafka、ActiveMQ、RabbitMQ、RocketMQ四大消息队列优劣对比与选择指南
    在分布式系统架构中,消息队列(MessageQueue,MQ)扮演着至关重要的角色,它作为异步通信的核心组件,能够实现系统解耦、削峰填谷、数据缓冲等功能。本文将聚焦于四大主流消息队列——Kafka、ActiveMQ、RabbitMQ、RocketMQ,深度剖析它们各自的优缺点,并在最后提供一份详尽的选择指南,以助......
  • 如何使用Java和RabbitMQ实现延迟队列(方式二)?
    前言昨天写了一篇关于Java和RabbitMQ使用插件实现延迟队列功能的文章,今天来讲下另外一种方式,不需要RabbitMQ的插件。前期准备,需要安装好docker、docker-compose的运行环境。需要安装RabbitMQ的可以看下面这篇文章。如何使用PHP和RabbitMQ实现消息队列?-CSDN博客使用RabbitM......
  • 如何使用Java和RabbitMQ实现延迟队列?
    前言今天我们使用Java和RabbitMQ实现消息队列的延迟功能。前期准备,需要安装好docker、docker-compose的运行环境。需要安装RabbitMQ的可以看下面这篇文章。如何使用PHP和RabbitMQ实现消息队列?-CSDN博客今天讲的是依赖RabbitMQ的延迟插件实现消息队列的延迟功能。如何安装......
  • rabbitmq
    消费端限流/**设置限流机制*param1:prefetchSize,消息本身的大小如果设置为0那么表示对消息本身的大小不限制*param2:prefetchCount,告诉rabbitmq不要一次性给消费者推送大于N个消息*param3:global,是否将上面的设置应用于整个通道,false表示只应用于当前消费者......
  • Spring Boot 集成 RabbitMQ(一)
    1、RabbitMQ和SpringBoot的基础概念RabbitMQ 是一个开源的MQ(MessageQueue,消息队列)客户端服务器实现,遵循AMQP(AdvancedMessageQueuingProtocol)协议。它允许应用发送消息并不直接传递到目标对象,而是通过交换器,队列,绑定的方式进行处理和转发,从而实现应用的解耦,异步......
  • RabbitMQ3.x之六_RabbitMQ使用场景
    RabbitMQ3.x之六_RabbitMQ使用场景文章目录RabbitMQ3.x之六_RabbitMQ使用场景1.为什么选择RabbitMQ?1.可互操作2.灵活3.可靠2.常见用户案例1.服务解耦2.远程过程调用3.流处理4.物联网1.为什么选择RabbitMQ?RabbitMQ是一个可靠且成熟的消息传递和流代......
  • 天翼云充值:分布式消息服务RabbitMQ支持AMQP协议,兼容RabbitMQ生态
    天翼云充值:分布式消息服务RabbitMQ支持AMQP协议,兼容RabbitMQ生态简介:飞机@luotuoemo本文由(天翼云代理商:【金推云】www.jintui.cn)撰写天翼云:支持AMQP协议的RabbitMQ服务分布式消息服务RabbitMQ是一种开源的、基于Erlang语言的消息代理和队列服务器。RabbitMQ最大的特性就......
  • 机器学习实践篇第二篇-KNN算法学习
    一.了解什么是K-NN算法  1.KNN算法原理KNN(K-NearestNeighbor)算法是机器学习算法中最基础、最简单的算法之一。它既能用于分类,也能用于回归。KNN通过测量不同特征值之间的距离来进行分类。KNN算法的思想非常简单:对于任意n维输入向量,分别对应于特征空间中的一个点,输出为......