在我的應(yīng)用程序中，我使用 JAXB 將對象轉(zhuǎn)換為 XML。我需要將此 XML 文件傳輸?shù)?ActiveMQ 隊列。以前我以這樣的字符串形式將消息發(fā)送到隊列：public class Main { private static String url = ActiveMQConnection.DEFAULT_BROKER_URL; private static String subject = "TestQueue"; public static void main(String[] args) throws JMSException { ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url); Connection connection = connectionFactory.createConnection(); connection.start(); Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue(subject); MessageProducer producer = session.createProducer(destination); TextMessage message = session.createTextMessage("secondMessage "); producer.send(message); connection.close(); }}但現(xiàn)在我需要傳輸 XML 文件。我怎樣才能做到這一點？
1 回答
交互式愛情
TA貢獻1712條經(jīng)驗 獲得超3個贊
在 JMS（以及一般的消息傳遞）中，您發(fā)送的是消息而不是文件。您可以通過從文件中讀取數(shù)據(jù)并將其放入 JMS 文本或字節(jié)消息中來將文件轉(zhuǎn)換為消息。最簡單的解決方案是這樣的：
public class Main {
private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
private static String subject = "TestQueue";
public static void main(String[] args) throws JMSException {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(subject);
MessageProducer producer = session.createProducer(destination);
String xml = readXmlFromFile();
TextMessage message = session.createTextMessage(xml);
producer.send(message);
connection.close();
}
private static String readXmlFromFile() {
// read XML from file
}
}
添加回答
舉報
0/150
提交
取消