JMS点对点聊天

Question

我正在尝试进行简单的点对点聊天，但在运行该程序后，我遇到了一个异常：

javax.naming.CommunicationException: Failed to get registry service for URL: tcp://localhost:8080/ [Root exception is java.rmi.ConnectIOException: Failed to create connection; nested exception is: 
    org.exolab.jms.net.connector.ConnectException: Failed to connect to localhost:8080]
    at org.exolab.jms.jndi.InitialContextFactory.getInitialContext(InitialContextFactory.java:146)
    at java.naming/javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:732)
    at java.naming/javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:305)
    at java.naming/javax.naming.InitialContext.init(InitialContext.java:236)
    at java.naming/javax.naming.InitialContext.<init>(InitialContext.java:208)
    at zad1.Receiver.<init>(Receiver.java:24)
    at zad1.Client.lambda$new$0(Client.java:61)
    ....

有什么问题吗？我在这方面完全是个初学者。

这是我的代码：

    private Context context;
    private Connection connection = null;
    private Session session;
    private MessageProducer sender;

    public Sender() {
        try {
            Hashtable<String, String> properties = new Hashtable<>();
            properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.exolab.jms.jndi.InitialContextFactory");
            properties.put(Context.PROVIDER_URL, "tcp://localhost:8080/");

            context = new InitialContext(properties);
            ConnectionFactory factory = (ConnectionFactory) context.lookup("ConnectionFactory");
            Topic topic = (Topic) context.lookup("topic1");

            connection = factory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            sender = session.createProducer(topic);
            connection.start();
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(1);
        }
    }

    public void send(String message) {
        try {
            TextMessage textMessage = session.createTextMessage();
            textMessage.setText(message);
            sender.send(textMessage);
        } catch (JMSException ex) {
            ex.printStackTrace();
        }
    }

Answer 1

来自异常的消息指示问题是什么：

Failed to connect to localhost:8080

配置JNDI查找时，请指定：

properties.put(Context.PROVIDER_URL, "tcp://localhost:8080/");

但是，JNDI实现无法建立到本地主机8080的连接。请确保URL适合您的环境和/或JNDI服务器实际运行在本地主机上的端口8080上。

最后，值得注意的是，您共享的异常的堆栈跟踪与您共享的源代码不匹配。堆栈跟踪来自名为Receiver的类的构造函数，但您共享的源代码是针对名为Sender的类的。