我刚开始使用 JMS 所以我举了一个 例子 ,它就像一个魅力!当我在控制台中输入消息时,订阅者收到了消息,但该示例仅基于一个文件,因此我决定将其拆分为发布者文件和订阅者文件,但它不起作用,订阅者不阅读消息!我从另一个示例中插入了一些代码,但仍然没有,我不明白为什么当我的程序编译完美而没有错误时,有人知道为什么它不读取消息吗?
我的 Subscriver.java 文件是:
package main;
import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import com.sun.messaging.Destination;
public class Subscriver1 {
private TopicSession subSession;
private TopicSubscriber subscriver;
private TopicConnection connection;
private String username;
Destination dest;
public Subscriver1(String topicName, String username, String password)
throws NamingException, JMSException {
Properties env = new Properties();
InitialContext jndi = new InitialContext(env);
TopicConnectionFactory conFactory = (TopicConnectionFactory) jndi
.lookup("topicConn");
TopicConnection connection = conFactory.createTopicConnection(username,
password);
TopicSession subSession = connection.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
Topic chatTopic = (Topic) jndi.lookup(topicName);
TopicSubscriber subscriver = subSession.createSubscriber(chatTopic,
null, true);
Destination dest = (Destination) jndi.lookup(topicName);
set(connection, subSession, subscriver, username, dest);
connection.start();
}
private void set(TopicConnection connection2, TopicSession subSession2,
TopicSubscriber subscriver2, String username2, Destination dest2) {
this.connection = connection2;
this.subSession = subSession2;
this.subscriver = subscriver2;
this.username = username2;
this.dest = dest2;
}
public void close() throws JMSException {
connection.close();
}
public void read() throws JMSException {
while (true) {
MessageConsumer consumer = subSession.createConsumer(dest);
;
Message m = consumer.receive(1);
if (m != null) {
if (m instanceof TextMessage) {
TextMessage message = (TextMessage) m;
System.out.println("Reading message: " + message.getText());
} else {
break;
}
}
}
}
public void onMessage(Message message) {
try {
TextMessage textMessage = (TextMessage) message;
String text = textMessage.getText();
System.out.println(text);
} catch (JMSException jmse) {
jmse.printStackTrace();
}
}
public static void main(String[] args) throws NamingException, JMSException {
Subscriver1 lexoMesazhin = new Subscriver1("kanaliTopic", "user",
"user");
lexoMesazhin.read();
lexoMesazhin.close();
}
}
我的文件 Publisher.java 文件是
package main;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.Properties;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class Publisher {
private TopicSession pubSession;
private TopicPublisher publisher;
private TopicConnection connection;
private String username;
public Publisher(String topicName, String username, String password)
throws NamingException, JMSException {
Properties env = new Properties();
InitialContext jndi = new InitialContext(env);
TopicConnectionFactory conFactory = (TopicConnectionFactory) jndi
.lookup("topicConn");
TopicConnection connection = conFactory.createTopicConnection(username,
password);
TopicSession pubSession = connection.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
Topic chatTopic = (Topic) jndi.lookup(topicName);
TopicPublisher publisher = pubSession.createPublisher(chatTopic);
set(connection, pubSession, publisher, username);
connection.start();
}
private void set(TopicConnection connection2, TopicSession pubSession2,
TopicPublisher publisher2, String username2) {
this.connection = connection2;
this.pubSession = pubSession2;
this.publisher = publisher2;
this.username = username2;
}
protected void createMesage(String text) throws JMSException {
TextMessage mesazhi = pubSession.createTextMessage(text);
mesazhi.setText(username + " >> " + text);
}
public void close() throws JMSException {
connection.close();
}
public static void main(String[] args) throws NamingException,
JMSException, IOException {
Publisher dergonMesazhin = new Publisher("kanaliTopic", "andi", "andi");
BufferedReader commandLine = new java.io.BufferedReader(
new InputStreamReader(System.in));
try {
while (true) {
String s = commandLine.readLine();
if (s.equalsIgnoreCase("exit")) {
dergonMesazhin.close();
System.exit(0);
} else
dergonMesazhin.createMesage(s);
}
} catch (IOException e) {
}
}
}