小编Pet*_*nes的帖子

RabbitMQ 发送对象

您好,我是 RabbitMQ 的新手,我正在尝试在 2 个应用程序之间发送一个对象,但它不起作用然后我发现我需要序列化和反序列化这些对象,但它仍然无法正常工作。当我发送一个字符串时没有问题,但是对于对象它突然不起作用,应用程序之间没有连接,我不确定我做错了什么。

这是 Sender.java :

import org.apache.commons.lang3.SerializationUtils;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;

import java.io.ByteArrayOutputStream;
import java.io.ObjectOutput;
import java.io.ObjectOutputStream;

public class App {

private final static String QUEUE_NAME = "12345";

public static void main(String[] argv) throws Exception {

    ConnectionFactory factory = new ConnectionFactory();

    factory.setHost("somehost"); 
    factory.setUsername("guest"); 
    // factory.setPassword( "password" ); 
    //factory.setPort( 12345 ); 

    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();

    channel.queueDeclare(QUEUE_NAME, false, false, false, null);

    Car car = new Car(4, 4, "Mercedes");

    byte[] data = SerializationUtils.serialize(car);

    channel.basicPublish("", …
Run Code Online (Sandbox Code Playgroud)

java networking system-integration rabbitmq

5
推荐指数
1
解决办法
4579
查看次数

标签 统计

java ×1

networking ×1

rabbitmq ×1

system-integration ×1