如何在Windows中的Rabbitmq如何启动-Toy模板网

这篇具有很好参考价值的文章主要介绍了如何在Windows中的Rabbitmq如何启动。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1.如何在Windows中的Rabbitmq如何启动

1、进入rabbitmq的sbin目录，输入CMD，然后按下enter(回车键)

windows启动rabbitmq,rabbitmq,分布式

2、在命令窗口中输入： rabbitmq-plugins enable rabbitmq_management 启用管理服务。

3、在命令窗口中输入： rabbitmqctl start_app 启动服务。

查看是否启动成功

如果不行的话就试试进入rabbitmq的sbin目录，进入CMD 在命令提示符里输入：Rabbitmq-server 启动

windows启动rabbitmq,rabbitmq,分布式

出现这样的页面就证明启动成功了！

1、浏览器访问http://localhost:15672/

输入账号：guest（你的账号），密码：guest（你的密码）点击登录

停止服务的命令: Rabbitmq-service stop

windows启动rabbitmq,rabbitmq,分布式

这样就成功了！

2.如何在java中使用Rabbitmq呢？

1.先添加依赖

       <!--AMQP依赖，包含RabbitMQ-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

2.消息生成队列

生成消息队列方法一：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import org.junit.Test;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * 消息队列原生的生成方法
 */
public class PublisherTest {



    @Test
    public void testSendMessage() throws IOException, TimeoutException {
        // 1.建立连接
        ConnectionFactory factory = new ConnectionFactory();
        // 1.1.设置连接参数，分别是：主机名、端口号、vhost、用户名、密码
        factory.setHost("127.0.0.1");
        factory.setPort(5672);
        factory.setVirtualHost("/");
        factory.setUsername("guest"); // 你的rabbitMQ的账号
        factory.setPassword("guest"); // 你的rabbitMQ的密码
        // 1.2.建立连接
        Connection connection = factory.newConnection();

        // 2.创建通道Channel
        Channel channel = connection.createChannel();

        // 3.创建队列
        String queueName = "simple.queue";
        channel.queueDeclare(queueName, false, false, false, null);

        // 4.发送消息
        String message = "hello, rabbitmq!";
        channel.basicPublish("", queueName, null, message.getBytes());
        System.out.println("发送消息成功：【" + message + "】");

        // 5.关闭通道和连接
        channel.close();
        connection.close();

    }
}

生成消息队列方法二：

@RunWith(SpringRunner.class)
@SpringBootTest
public class publisher{

	@Autowired
	private RabbitTemplate rabbitTemplate;

	@Test
	//  发送消息队列
	public void testSendMessage2SimpleQueue(){
//      队列名称
		String queueName = "simple.queue";
//      消息
		String message = "你好啊, rabbitmq!";
		rabbitTemplate.convertAndSend(queueName,message);
	}

3.消息消费队列

@Component
public class consumer {

// 获取那个消息队列    消息队列的名称
	@RabbitListener(queues = "simple.queue")
	public  void  listenSimpleQueueMessage(String message) {
//
		System.out.println("spring 消费者接收到的消息是："+message);
	}

}

4.yml配置文件

spring:
  rabbitmq:
    host: 127.0.0.1 # rabbitMQ的ip地址
    port: 5672 # 端口
    username: guest  # rabbitmq的账号
    password: guest    # rabbitmq的密码
    virtual-host: /

文章来源地址https://www.toymoban.com/news/detail-715143.html

到了这里，关于如何在Windows中的Rabbitmq如何启动的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！