RabbitMQ--02--RabbitMQ传递对象

方案一：对象序列化
其实和hello world类似，只不过增加了一个对象序列化：
序列化就是将一个对象的状态（各个属性量）保存起来，然后在适当的时候再获得。序列化分为两大部分：序列化和反序列化。序列化是这个过程的第一部分，将数据分解成字节流，以便存储在文件中或在网络上传输。反序列化就是打开字节流并重构对象。对象序列化不仅要将基本数据类型转换成字节表示，有时还要恢复数据。恢复数据要求有恢复数据的对象实例。

发送端：

public class Send {
    /**
     * mq通信的名称
     */
    private final static String QUEUE_NAME="hello";

    public static void main(String[] args) throws IOException, TimeoutException{
        ConnectionFactory connFactory=new ConnectionFactory();
        //设置服务器位置
        connFactory.setHost("localhost");
        //设置服务器端口号
        //connFactory.setPort(5672);
        //创建连接
        Connection con=connFactory.newConnection();
        //创建channel
        Channel channel=con.createChannel();
        //设置队列的属性第一个参数为队列名。第二个参数为是否创建一个持久队列，第三个是否创建一个专用的队列，
        //第四个参数为是否自动删除队列，第五个参数为其他属性（结构参数）
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        //String message="hello world";
        //创建一个对象
        User user=new User();
        user.setId(1);
        user.setName("dema");
        user.setPassword("123");
        //将创建的对象序列化后传递
        //第一个参数为，第二个参数为队列名。第三个参数为其他属性。第四个参数为消息体
        channel.basicPublish("",QUEUE_NAME,null,SerializationUtils.serialize(user));
        System.out.println("正在发送消息："+user.getId());     
        //关闭连接
        channel.close();
        con.close();
    }
}

接收端：

import java.io.IOException;
import java.util.concurrent.TimeoutException;
import org.apache.commons.lang3.SerializationUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConsumerCancelledException;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;
import com.rabbitmq.client.ShutdownSignalException;
public class Receive {

    /**
     * 定义rm通信的名称
     */
    private final static String QUEUE_NAME="hello";


    public static void main(String[] args) throws IOException, TimeoutException, ShutdownSignalException, ConsumerCancelledException, InterruptedException {
        // TODO Auto-generated method stub

        ConnectionFactory connFactory=new ConnectionFactory();

        //设置服务器位置
        connFactory.setHost("localhost");
        //设置端口号
        //connFactory.setPort(15672);
        //连接登录用户名
        //connFactory.setPassword("guest");
        //连接登录密码
        //connFactory.setUsername("guest");

        //创建连接
        Connection con=connFactory.newConnection();

        //创建channel
        Channel channel=con.createChannel();

        //设置队列的属性第一个参数为队列名。第二个参数为是否创建一个持久队列，第三个是否创建一个专用的队列，
                //第四个参数为是否自动删除队列，第五个参数为其他属性（结构参数）
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        QueueingConsumer consumer=new QueueingConsumer(channel);
        //第一个参数为队列名，第二个参数是否考虑已发送的消息，第三个参数为消费对象的接口
        channel.basicConsume(QUEUE_NAME, true, consumer);

        System.out.println("Receiv类正在等待Send类发送消息");
        while(true){
            Delivery delivery=consumer.nextDelivery();
            //String message=new String(delivery.getBody()); 
            //将传递过来的对象反序列化
            @SuppressWarnings("deprecation")
            User user=(User)SerializationUtils.deserialize(delivery.getBody());
            //System.out.println("Receive类接收到Send类发送的信息："+message);
            System.out.println(user.getName());
        }

        //关闭连接
    }
}

方案二：通过ObjectMapper将对象转换成JSON数据：
发送端：

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

import org.apache.commons.lang3.SerializationUtils;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;


public class Send {
    /**
     * mq通信的名称
     */
    private final static String QUEUE_NAME="hello";

    public static void main(String[] args) throws IOException, TimeoutException{
        ConnectionFactory connFactory=new ConnectionFactory();
        //设置服务器位置
        connFactory.setHost("localhost");
        //设置服务器端口号
        //connFactory.setPort(5672);
        //创建连接
        Connection con=connFactory.newConnection();
        //创建channel
        Channel channel=con.createChannel();
        //设置队列的属性第一个参数为队列名。第二个参数为是否创建一个持久队列，第三个是否创建一个专用的队列，
        //第四个参数为是否自动删除队列，第五个参数为其他属性（结构参数）
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        //String message="hello world";

        //创建一个对象
        User user=new User();
        user.setId(1);
        user.setName("dema");
        user.setPassword("123");

        //将Java对象匹配JSON结构
        ObjectMapper mapper=new ObjectMapper();
        String message=mapper.writeValueAsString(user);
        channel.basicPublish("",QUEUE_NAME,null,message.getBytes());

        System.out.println("正在发送消息："+user.getId());     
        //关闭连接
        channel.close();
        con.close();
        //SimpleMessageConverter


    }
}

接收端：

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

import org.apache.commons.lang3.SerializationUtils;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConsumerCancelledException;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;
import com.rabbitmq.client.ShutdownSignalException;


public class Receive {

    /**
     * 定义rm通信的名称
     */
    private final static String QUEUE_NAME="hello";


    public static void main(String[] args) throws IOException, TimeoutException, ShutdownSignalException, ConsumerCancelledException, InterruptedException {
        // TODO Auto-generated method stub

        ConnectionFactory connFactory=new ConnectionFactory();

        //设置服务器位置
        connFactory.setHost("localhost");
        //设置端口号
        //connFactory.setPort(15672);
        //连接登录用户名
        //connFactory.setPassword("guest");
        //连接登录密码
        //connFactory.setUsername("guest");

        //创建连接
        Connection con=connFactory.newConnection();

        //创建channel
        Channel channel=con.createChannel();

        //设置队列的属性第一个参数为队列名。第二个参数为是否创建一个持久队列，第三个是否创建一个专用的队列，
                //第四个参数为是否自动删除队列，第五个参数为其他属性（结构参数）
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        QueueingConsumer consumer=new QueueingConsumer(channel);
        //第一个参数为队列名，第二个参数是否考虑已发送的消息，第三个参数为消费对象的接口
        channel.basicConsume(QUEUE_NAME, true, consumer);

        System.out.println("Receiv类正在等待Send类发送消息");
        while(true){

            //将json数据转成对象
            ObjectMapper mapper=new ObjectMapper();
            Delivery delivery=consumer.nextDelivery();
            String message=new String(delivery.getBody());
            User user=mapper.readValue(message.getBytes("utf-8"),User.class);
            System.out.println(user.getName());
        }

        //关闭连接
    }

}

说明都在注释中。
附带遇到的问题及解决办法：

Exception in thread "main" java.lang.NoClassDefFoundError: org/slf4j/ILoggerFactory
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:791)
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)
at java.net.URLClassLoader.access$100(URLClassLoader.java:71)
at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:186)
..........

Failed to instantiate SLF4J LoggerFactory
Reported exception:
java.lang.NoClassDefFoundError: org/apache/log4j/Level
    at org.slf4j.LoggerFactory.bind(LoggerFactory.java:150)
    at org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:124)
    at org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:412)
    at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:357)
    at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:383)
    at com.rabbitmq.client.impl.AMQConnection.<clinit>(AMQConnection.java:49)
    at com.rabbitmq.client.ConnectionFactory.<init>(ConnectionFactory.java:91)
    at Receive.main(Receive.java:24)
Caused by: java.lang.ClassNotFoundException: org.apache.log4j.Level
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 8 more
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/log4j/Level
    at org.slf4j.LoggerFactory.bind(LoggerFactory.java:150)
    at org.slf4j.LoggerFactory.performInitialization(LoggerFactory.java:124)
    at org.slf4j.LoggerFactory.getILoggerFactory(LoggerFactory.java:412)
    at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:357)
    at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:383)
    at com.rabbitmq.client.impl.AMQConnection.<clinit>(AMQConnection.java:49)
    at com.rabbitmq.client.ConnectionFactory.<init>(ConnectionFactory.java:91)
    at Receive.main(Receive.java:24)
Caused by: java.lang.ClassNotFoundException: org.apache.log4j.Level
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 8 more

解决方案：缺少日志架包
添加三个架包：
log4j-1.2.17.jar
slf4j-api-1.6.4-sources.jar
slf4j-api-1.6.4.jar
slf4j-log4j12-1.7.0-sources.jar
slf4j-log4j12-1.7.0.jar
参考网站：
http://outofmemory.cn/code-snippet/6776/java.lang.NoClassDefFoundError-org-slf4j-LoggerFactory

Exception in thread "main" java.net.ConnectException: Connection refused: connect
    at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
    at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85)
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
    at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    at java.net.Socket.connect(Socket.java:589)
    at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:50)
    at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:60)
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:99)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:900)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:859)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:817)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:954)
    at Receive.main(Receive.java:30)

安装后在浏览器中通过url无法访问
解决方案：
给path变量添加内容，在其后面增加：;%RABBITMQ_SERVER%\sbin （注意前面的分号），然后确定即可
添加环境变量：RABBITMQ_SERVER
环境变量RABBITMQ_SERVER 的值为：D:\My-Softwar-Installed\RabbitMQ Server\rabbitmq_server-
配置环境变量后cmd中输入
rabbitmq-plugins enable rabbitmq_management
然后运行下面的命令来安装：
rabbitmq-service stop
rabbitmq-service install
rabbitmq-service start

Exception in thread "main" log4j:WARN No appenders could be found for logger (com.rabbitmq.client.impl.ForgivingExceptionHandler).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
java.util.concurrent.TimeoutException
    at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:77)
    at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:120)
    at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)
    at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:372)
    at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:297)
    at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:62)
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:99)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:900)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:859)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:817)
    at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:954)
    at Receive.main(Receive.java:31)

解决方案：
将log4j.properties添加到classpath下
http://blog.csdn.net/huoyin/article/details/41593013

rabbitmq的web管理界面无法使用guest用户登录
解决方案：由chrome换成360浏览器
附demo下载链接：http://download.csdn.net/detail/btwangzhi/9752777

原文链接：https://blog.csdn.net/UncleTian/article/details/80172354