java - JMS 生产者的最低限度代码

Question

我真的很难为 JMS 生产者获取工作的最低限度代码，我已经启动并运行了我的 WL JMS 服务器，并准备使用 JMS 客户端对其进行测试，但是为了创建客户端，我在使用时遇到了问题初始上下文工厂，即 env.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");。我已经尝试了几乎所有代码，使用 WL 初始上下文工厂、oracle j2ee 初始上下文工厂 (env.put(Context.INITIAL_CONTEXT_FACTORY, "oracle.j2ee.rmi.RMIInitialContextFactory");) 但我总是得到当我运行代码时，没有类定义发现异常。例如，对于下面的代码，我没有找到类定义异常。

我正在尝试将客户端作为独立的 Java 程序运行。我理解这个异常，并尝试添加相关的 JAR，例如，当我使用 WL 初始上下文工厂时，然后我将 WL 完整客户端 JAR 放置在类路径中，但我仍然无法克服这个 no class def found 异常。

有人可以链接到某个存储库或博客，或者为我提供一个最低限度的“工作”JMS 生成器，或者指出我做错了什么。

请注意，我的 JMS 服务器是 WL，我正在尝试创建一个简单的 JMS 客户端，而不使用 ActiveMQ 库，但我也标记了 ActiveMQ，以便它可以获得更多关注，但如果有人认为这是错误的那么请告诉我，我将删除 ActiveMQ 标签，或者请自行删除。

我的客户示例:

import java.util.Hashtable;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class JmsProducerQueueClient {
    public static void main(String[] args) throws NamingException, JMSException {
        Connection connection = null;
        try {
            System.out.println("Create JNDI Context");
            Context context = getInitialContext();

            System.out.println("Get connection facory");
            ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("/com/jms/ms1/cf1");

            System.out.println("Create connection");
            connection = connectionFactory.createConnection();

            System.out.println("Create session");
            Session session = connection.createSession(false, QueueSession.AUTO_ACKNOWLEDGE);

            System.out.println("Lookup queue");
            Queue queue = (Queue) context.lookup("/com/jms/ms1/q1");

            System.out.println("Start connection");
            connection.start();

            System.out.println("Create producer");
            MessageProducer producer = session.createProducer(queue);

            System.out.println("Create hello world message");
            Message hellowWorldText = session.createTextMessage("Hello World!");

            System.out.println("Send hello world message");

            producer.send(hellowWorldText);
        } finally {
            if (connection != null) {
                System.out.println("close the connection");
                connection.close();
            }
        }

    }

    public static Context getInitialContext() throws NamingException {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
        //env.put(Context.INITIAL_CONTEXT_FACTORY, "oracle.j2ee.rmi.RMIInitialContextFactory");
        env.put(Context.PROVIDER_URL, "tcp://localhost:6007");
        Context context = new InitialContext(env);
        return context;
    }
}

日志:

Create JNDI Context
Exception in thread "main" java.lang.NoClassDefFoundError: weblogic/security/service/PrivilegedActions
    at weblogic.jndi.WLSJNDIEnvironmentImpl.<clinit>(WLSJNDIEnvironmentImpl.java:57)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:190)
    at weblogic.jndi.internal.JNDIEnvironment.getJNDIEnvironment(JNDIEnvironment.java:37)
    at weblogic.jndi.Environment.<clinit>(Environment.java:92)
    at weblogic.jndi.WLInitialContextFactory.getInitialContext(WLInitialContextFactory.java:117)
    at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:684)
    at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:307)
    at javax.naming.InitialContext.init(InitialContext.java:242)
    at javax.naming.InitialContext.<init>(InitialContext.java:216)
    at com.learning.so.question.jms.queue.producerconsumer.JmsProducerQueueClient.getInitialContext(JmsProducerQueueClient.java:62)
    at com.learning.so.question.jms.queue.producerconsumer.JmsProducerQueueClient.main(JmsProducerQueueClient.java:22)

Answer 1

我设法让你的代码在我这边工作，所以我认为你的问题来自于缺少依赖项，从 weblgogic 客户端可以肯定。可能是您打包应用程序的方式有问题。

因此，我将公开我所做的事情，仅使用我自己的队列名称和工厂名称。

请注意，此测试是在 WLS 12.1.3 上完成的。

Weblogic客户端

首先，我从 wlthint3client.jar 创建了一个 Maven 依赖项，该依赖项可以在 weblogic 服务器上的 ${ORACLE_HOME}/wlserver/server/lib 中使用 mvn install:安装文件命令:

mvn install:install-file -Dfile=wlthint3client.jar -DgroupId=weblogic -DartifactId=wlthint3client -Dversion=12.1.3.0.0 -Dpackaging=jar

这样，我现在可以在所有 Maven 项目中使用以下依赖项:

<dependency>
  <groupId>weblogic</groupId>
  <artifactId>wlthint3client</artifactId>
  <version>12.1.3.0.0</version>
</dependency>

Weblogic JMS 工厂和队列

然后我在 weblogic 端创建了一个 JMSXAFactory 工厂和一个 test JMS 队列。

JMS 生产者项目

然后我创建了maven项目。这是pom.xml:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>org.jvi.weblogic.jms</groupId>
  <artifactId>jms-producer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>

  <name>jms-producer</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  </properties>

  <dependencies>

    <dependency>
      <groupId>weblogic</groupId>
      <artifactId>wlthint3client</artifactId>
      <version>12.1.3.0.0</version>
    </dependency>

    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
  </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-dependency-plugin</artifactId>
                <executions>
                    <execution>
                        <id>copy-dependencies</id>
                        <phase>prepare-package</phase>
                        <goals>
                            <goal>unpack-dependencies</goal>
                        </goals>
                        <configuration>
                            <includeScope>runtime</includeScope>
                            <outputDirectory>${project.build.outputDirectory}</outputDirectory>
                        </configuration>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

</project>

以及App类代码:

package org.jvi.weblogic.jms;

import java.util.Hashtable;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

/**
 * Hello world!
 *
 */
public class App 
{
    public final static String JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";

    public final static String  URL = "t3://localhost:7001";

    public static void main( String[] args ) throws NamingException, JMSException
    {
        System.out.println( "Hello World!" );

        Connection connection = null;
        try {
            System.out.println("Create JNDI Context");
            Context context = getInitialContext();

            System.out.println("Get connection facory");
            ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("JMSXAFactory");

            System.out.println("Create connection");
            connection = connectionFactory.createConnection();

            System.out.println("Create session");
            Session session = connection.createSession(false, QueueSession.AUTO_ACKNOWLEDGE);

            System.out.println("Lookup queue");
            Queue queue = (Queue) context.lookup("test");

            System.out.println("Start connection");
            connection.start();

            System.out.println("Create producer");
            MessageProducer producer = session.createProducer(queue);

            System.out.println("Create hello world message");
            Message hellowWorldText = session.createTextMessage("Hello World!");

            System.out.println("Send hello world message");

            producer.send(hellowWorldText);
        } finally {
            if (connection != null) {
                System.out.println("close the connection");
                connection.close();
            }
        }
    }

    private static InitialContext getInitialContext() throws NamingException
            {
              Hashtable env = new Hashtable();
              env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
              env.put(Context.PROVIDER_URL, URL);
              return new InitialContext(env);
            }
}

然后当我通过命令行启动应用程序时:

java -cp jms-producer-0.0.1-SNAPSHOT.jar org.jvi.weblogic.jms.App

结果

启动此命令后，我可以看到消息在 test 队列中正确生成: