zoukankan      html  css  js  c++  java
  • 3-简单生产+消费

    普通生产者

    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    import java.io.IOException;
    import java.util.Date;
    import java.util.concurrent.TimeoutException;
    
    public class MyProcuder {
        public static void main(String[] args) throws IOException, TimeoutException {
            ConnectionFactory connectionFactory = new ConnectionFactory();
            connectionFactory.setHost("192.168.205.10");
            connectionFactory.setPort(5672);
            connectionFactory.setUsername("admin");
            connectionFactory.setVirtualHost("/");
            connectionFactory.setPassword("ai123");
    
            Connection connection = connectionFactory.newConnection();
            Channel channel = connection.createChannel();
            String msg = "Hello My RabbitMQ! t = "+(new Date().toString());
            channel.basicPublish("", "test001", null, msg.getBytes());
            channel.close();
            connection.close();
        }
    }
    

    普通消费者

    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    import com.rabbitmq.client.QueueingConsumer;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class MyConsumer {
    
        public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {
            ConnectionFactory connectionFactory = new ConnectionFactory();
            connectionFactory.setHost("192.168.205.10");
            connectionFactory.setPort(5672);
            connectionFactory.setUsername("admin");
            connectionFactory.setVirtualHost("/");
            connectionFactory.setPassword("ai123");
    
            Connection connection = connectionFactory.newConnection();
            Channel channel = connection.createChannel();
    
            String queueName = "test001";
            channel.queueDeclare(queueName, true, false, false, null);
    
            QueueingConsumer queueingConsumer = new QueueingConsumer(channel);
            channel.basicConsume(queueName, true, queueingConsumer);
    
            while(true){
                //7 获取消息
                QueueingConsumer.Delivery delivery = queueingConsumer.nextDelivery();
                String msg = new String(delivery.getBody());
                System.err.println("消费端: " + msg);
                //Envelope envelope = delivery.getEnvelope();
            }
    
        }
    }
    

    spring boot 项目pom配置

    <?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>
    
    	<groupId>com.bfxy</groupId>
    	<artifactId>rabbitmq-api</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>jar</packaging>
    
    	<name>rabbitmq-api</name>
    	<description>rabbitmq-api</description>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.5.14.RELEASE</version>
    		<relativePath/> <!-- lookup parent from repository -->
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		
    		<dependency>
    			<groupId>com.rabbitmq</groupId>
    			<artifactId>amqp-client</artifactId>
    			<version>3.6.5</version>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    
    </project>
  • 相关阅读:
    MySQL与SQLServer的update left join语法区别
    request获取真实IP
    request获取前台表单
    ehcache memcache redis 三大缓存
    StraUML简单教程
    JSP模板
    判断是否为同一天
    eneityManager的merge、Flush、Refresh方法
    javascript
    javax.naming.NameNotFoundException:Name[ XXX] is not bound in this context.
  • 原文地址:https://www.cnblogs.com/golden-elephant/p/12191170.html
Copyright © 2011-2022 走看看