2. 程式人生 > >RabbitMQ--02--RabbitMQ傳遞物件

RabbitMQ--02--RabbitMQ傳遞物件

阿新 • • 發佈：2018-11-10
方案一：物件序列化
其實和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


相關推薦

RabbitMQ--02--RabbitMQ傳遞物件

方案一：物件序列化 其實和hello world類似，只不過增加了一個物件序列化： 序列化就是將一個物件的狀態（各個屬性量）儲存起來，然後在適當的時候再獲得。序列化分為兩大部分：序列化和反序列化。序列化是這個過程的第一部分，將資料分解成位元組流，以便儲存在檔案中或在網路上傳輸。反序列化就是開

怎樣使用RabbitMQ傳遞物件

1.首先我們需要配置rabbit所需要的依賴 org.springframework.boot spring-boot-starter-amqp 2.在springboot中的application.yml裡面配置下面的這些資料 spring: rabbitmq: host: 127.0

8.RabbitMQ 消息傳遞Java對象

per 共享 idt sin 序列 技術分享 默認端口 發送 trac 通過消息服務器傳遞Java對象，Java類必須實現序列化接口，可以把Java對象轉化為字節數組，從消費者或生產者傳遞到另外一個JVM中，一定需要兩個JVM共享這個類，比如是UserInfo類。 1、

五、RabbitMQ-訊息可靠性傳遞實現方案

一、實現方案圖解 第一步 將要傳送的資訊進行對應資料庫的錄入，並且將傳送資訊的操作作為一條操作日誌錄入資料庫中設定狀態欄位status為0(傳送中)。 第二步 生產端將訊息傳送到RabbitMQ服務上。 第三步 RabbitMQ接收到訊息後，進行迴

RabbitMQ 和訊息傳遞常用一些術語

0.寫在前面 RabbitMQ 是一個訊息代理:它接受和轉發訊息。你可以把它想象成一個郵局:當你把你想要投寄的郵件放在一個郵箱裡時，你可以確定收信人先生或女士最終會把郵件寄給你的收件人。在這個類比中，RabbitMQ是一個郵箱、一個郵局和一個郵遞員。 Rabbi

mq系列rabbitmq-02叢集+高可用配置

一。 rabbitmq 叢集高可用介紹    rabbitmq的broker是由一個或者多個物理節點組成 rabbtmq程式之間共享使用者 虛擬主機 佇列 交換機，繫結和引數，也可以將多個節點 組合成一個叢集，所有的資料都會被拷貝到叢集中不同的節點 除了佇列資料  佇列資料

使用RabbitMQ放置自定義物件（不借助序列化工具，例如protobuffer）V2.0

如何使用RabbitMQ盛放自定義的物件呢？一般都會使用序列化工具在投放之前轉換一次，從MQ取回的時候再逆序列化還原為本地物件。這裡使用C++自帶的強制型別裝換，將本地物件的記憶體模型當做自然的序列化之後的資料，直接當做位元組流放到string物件中，從MQ取回的時候用同樣

使用mina傳遞物件注意問題點以及常見報錯異常處理

最常見的異常，一個是不能序列化java.io.NotSerializableException:，另一個就是java.io.InvalidClassException，還有java.nio.charset.MalformedInputException   1. 首先是客戶端和服務

我為什麼要選擇RabbitMQ ，RabbitMQ簡介，各種MQ選型對比

轉載自：https://www.sojson.com/blog/48.html   前言：     MQ 是什麼？佇列是什麼，MQ 我們可以理解為訊息佇列，佇列我們可以理解為管道。以管道的方式做訊息傳遞。 場景：

Thinking in java自讀筆記:傳遞物件與克隆

前提：對於常規資料型別而言，可以分為值型別和引用型別，值型別為我們常說的”主型別”，”值型別”直接將記憶體儲存在棧內,由系統自動釋放資源的資料型別；引用型別是由型別的實際值引用（類似於指標）表示的資料型別，即一個在棧上的引用指向一個在堆上的例項的型別。 一.值的傳遞 當將應用型別和值

java學習02（面向物件基礎）

1.物件可以簡單認識成一個記憶體塊，一個區域。 2.記憶體分為：棧記憶體，堆記憶體，方法區(堆的一部分，包括類的資訊，靜態方法，靜態變數，字串常量)，這點對理解很多東西都很有用 3.包先簡單理解成一個資料夾(域名倒著寫) 4.面向物件： 繼承： 類只能單繼承，接口才可以多繼承 子類建構函式呼叫前預

02-類和物件-動手動腦

1.以下程式碼為何無法通過編譯？哪出錯了？ 1 public class Test { 2 public static void main(String[] args) { 3 Foo obji=new Foo(); 4 } 5 } 6 class Foo{

【Ionic】——Ionic傳遞物件到後臺

1定義傳遞的物件的變數 integralProgram :{ pluginId:string ;//外掛id userId:string; //被加分人id,以及完成專案的使用者id idInfo:string[]; //被加分人id陣列 integr

RabbitMQ：RabbitMQ + Spring配置檔案rabbit標籤

RabbitMQ：RabbitMQ + Spring配置檔案rabbit標籤 1.消費者配置檔案和啟動類：  【Consumer.xml】： <?xml version="1.0" encoding="UTF-8"?> <beans xmln

【RabbitMq】rabbitMq訊息確認機制

  一、提出問題 生產者將訊息傳送出去後，訊息是否到達RabbitMq伺服器呢？預設的情況下，是不知道的 二、引入訊息確認機制 兩種方式：           1.AMQP實現事務機制     &

springmvc傳遞物件引數時讓為空的欄位不傳遞(開發筆記)

引入jar 我這裡用的spring boot 只要引入 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-

【RabbitMQ】 RabbitMQ安裝

　　MQ全稱為Message Queue, 訊息佇列（MQ）是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息（針對應用程式的資料）來通訊，而無需專用連線來連結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊，而不是通過直接呼叫彼此來通訊，直接呼叫通常是用於諸如遠端過程呼叫的

【RabbitMQ】 RabbitMQ配置開機啟動 【Erlang】原始碼安裝 【RabbitMQ】 RabbitMQ安裝

環境 　　系統：Linux(CentOS 7.2) 　　Erlang環境：21.1（安裝參考【Erlang】原始碼安裝） 　　RabbitMQ：3.7.9（安裝參考【RabbitMQ】 RabbitMQ安裝） 配置開機啟動 　　1、增加自啟動指令碼： 　　　　在/etc/init.d目錄下新建一個

FC 13.2 使用Intent傳遞物件（Serializable和Parcelable）

使用Intent的putExtra方法可以傳遞資料，但是不能直接來傳遞自定義的物件。接下來學習兩種床底物件的方式 Serializable方式 Parcelable方式 兩種方式的詳細講解   Serializable方式 Serializable是序

vue-axios-post方式傳遞物件至後臺

1.物件引數型別JSON化： data:JSON.parse(JSON.stringify(object)), 2.頭部資訊headers： "Content-Type": "application/json; charset=UTF-8" 3.service中請求方式寫為POST 4.後臺