.net下redis和rabbitmq简单用demo

发布时间:2018-11-15  栏目:NoSQL  评论:0 Comments

凡参考 一下个别篇博文整理了下。

先使装为用户在web管理页面中安set permission,如一旦不,不克连
消费端代码:

Redis: 
 https://www.cnblogs.com/5ishare/p/6492380.html

package test;


import com.rabbitmq.client.*;
import org.junit.Test;

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

/**
 * Created by alber on 2017/1/9.
 */
public class MyConsumer {
    @Test
    public void test() throws IOException, TimeoutException {
        String QUEUE_NAME = "hello";
        ConnectionFactory factory = new ConnectionFactory();
//      设置RabbitMQ地址
        factory.setHost("192.168.134.129");
        factory.setUsername("admin");
        factory.setPassword("admin123");
//      创建一个新的连接
        Connection connection = factory.newConnection();
//      创建一个频道
        Channel channel = connection.createChannel();
//      声明要关注的队列 -- 在RabbitMQ中,队列声明是幂等性的(一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同),也就是说,如果不存在,就创建,如果存在,不会对已经存在的队列产生任何影响。
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println("C [*] Waiting for messages. To exit press CTRL+C");
//      DefaultConsumer类实现了Consumer接口,通过传入一个频道,告诉服务器我们需要那个频道的消息,如果频道中有消息,就会执行回调函数handleDelivery

        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println("C [x] Received '" + message + "'");
            }
        };
//      自动回复队列应答

        channel.basicConsume(QUEUE_NAME, true, consumer);
        System.in.read();
    }


}

RabbitMq: 
 https://www.cnblogs.com/yangecnu/p/4227535.html

生产端代码:

话不多说,下面直接贴demo 百度云盘
地址: 

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.net.URISyntaxException;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.util.concurrent.TimeoutException;

/**
 * Created by alber on 2017/1/9.
 */
public class MyProducer {
    @Test
    public void test() throws IOException, TimeoutException {
        String QUEUE_NAME = "hello";
        ConnectionFactory factory = new ConnectionFactory();
//      设置RabbitMQ地址
        factory.setHost("192.168.134.129");
        factory.setPort(5672);
        factory.setUsername("admin");
        factory.setPassword("admin123");
//      创建一个新的连接
        Connection connection = factory.newConnection();
//      创建一个频道
        Channel channel = connection.createChannel();
//      声明一个队列 -- 在RabbitMQ中,队列声明是幂等性的(一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同),也就是说,如果不存在,就创建,如果存在,不会对已经存在的队列产生任何影响。
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        String message = "Hello World!";
//      发送消息到队列中
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
        System.out.println("P [x] Sent '" + message + "'");
//      关闭频道和连接
        channel.close();
        connection.close();

    }
}

https://pan.baidu.com/s/1H0kBmt9crn6LU2aCjxmyCg

提取码 :  6pg5

 

留下评论

网站地图xml地图