Oracle：发送JMS消息的Java存储过程 [英] Oracle: Java stored procedure sending JMS Message
问题描述
我正在尝试从oracle数据库存储过程向java应用程序发送点对点JMS消息。这两个'点'位于不同的机器上，我已经确认可以通过ping相互通信。
I am attempting to send a Point-to-Point JMS message from an oracle database stored procedure to a java application. The two 'points' sit on different machines, which I've confirmed can talk to each other via ping.
我创建了一个能够成功接收消息的java应用程序关闭应用程序服务器中的队列。该应用程序在JBoss v4.2.3服务器中运行。我已经能够从远程Java应用程序成功发送JMS消息，因此我确信服务器中运行的代码是正常的。
I've created a java application able to successfully take messages off a queue within the application server. The application is running within a JBoss v4.2.3 server. I've been able to successfully send a JMS message from a remote java application, so I'm sure the code running within the server is ok.
我已经采取了来自工作的远程Java应用程序的代码，并将其成功加载到oracle存储过程中。我还设法（我相信！）使用loadjava实用程序将所需的jar文件加载到oracle中。我加载的三个jar文件是：
I've taken code from the working remote java application and loaded this successfully into an oracle stored procedure. I've also managed to (I believe!) load into oracle the required jar files using the loadjava utility. The three jar files I've loaded in are:
* jms-1.1
* jbossmq-3.2.3
* jboss-client-4.0.2
三个罐子在工作的远程java中使用应用程序，似乎是所有需要的。包含在存储过程中的代码如下：
The three jars are used within the working remote java application and appear to be all that's required. The code contained loaded into the stored procedure is as follows:
package com.base.jms.client;
import java.util.Hashtable;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
public class StandAloneClient {
public static String send() throws Exception {
String result = "Starting -> ";
try {
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
env.put(Context.PROVIDER_URL, "192.168.111.242:1099");
env.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");
result = result + "Environment -> ";
// set up stuff
Context ic = new InitialContext(env);
result = result + "Context -> ";
QueueConnectionFactory connectionFactory = (QueueConnectionFactory) ic.lookup("ConnectionFactory");
result = result + "Factory -> ";
Queue queue = (Queue) ic.lookup("queue/A");
result = result + "Queue -> ";
QueueConnection connection = connectionFactory.createQueueConnection();
result = result + "Connection -> ";
QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
result = result + "Session -> ";
QueueSender sender = session.createSender(queue);
connection.start();
result = result + "Sender -> ";
TextMessage myMessage = session.createTextMessage();
myMessage.setText(result);
sender.send(myMessage);
result = result + "Sending Message -> ";
sender.close();
session.close();
connection.close();
result = result + "Close";
} catch (JMSException e) {
result = result + "JMS Exception";
/*
if(e.getMessage() != null) {
result = result + ":" + e.getMessage();
}*/
} catch (Exception e) {
result = result + "Exception";
/*
if(e.getMessage() != null) {
result = result + ":" + e.getMessage();
}*/
}
return result;
}
}
我添加了结果字符串因此，我可以尝试确定它在代码中的位置。要创建并测试此过程，我在sqlplus中执行以下命令：
I've added the result string in so I can try and determine where in the code it's falling over. To create and test this procedure, I'm executing the following commands in sqlplus:
create or replace function send_jms return VARCHAR2 as language java name 'com.base.jms.client.StandAloneClient.send() return java.lang.String';
variable myString varchar2(20);
call send_jms() into :myString;
Call completed.
print myString;
似乎所有内容都已加载并正确编译，但邮件未发送。返回的结果字符串表示它在尝试从InitialContext中检索QueueConnectionFactory类时会崩溃。返回的结果字符串是：
Everything seems to be loaded and compiling correctly, however the message is not being sent. The result string returned implicates it's falling over when attempting to retrieve the QueueConnectionFactory class from the InitialContext. The result string returned is:
Starting -> Environment -> Context -> Exception
我不知道为什么这不起作用，并且无法收集更多来自Exception抛出。任何人都可以确认我这样做是正确的，如果我是这样，看看我做错了什么？
I'm at a loss as to why this is not working, and have been unable to glean more from the Exception thrown. Can anyone confirm that I am doing this correctly, and if I am, see what I am doing wrong?
长篇大论道歉但是提前感谢你们的看法它！
Apologies for the long post but thank you in advance for looking at it!
推荐答案
我不是在Oracle数据库中运行Java和JMS的专家（尽管我知道每个三个组成部分）。但是根据您的描述，您似乎没有考虑Java的Oracle安全模型。
I'm not exactly an expert about running Java and JMS within the Oracle database (though I know each of the three components separately). But from your description it seems you haven't taken the Oracle security model for Java into consideration.
Oracle不允许任何组件访问网络（或文件系统等） 。）没有明确授予权利。因此，请继续阅读 Oracle JVM安全性了解如何配置Oracle以允许您连接到远程计算机。
Oracle will not let any component access the network (or the file system etc.) without having explicitly being granted the right to. So start reading about Oracle JVM security to learn how you might need to configure Oracle for letting you connect to a remote machine.
授予权限可能涉及以下声明：
Granting the permissions could involve the following statement:
EXEC DBMS_JAVA.GRANT_PERMISSION('YOUR_SCHEMA', 'SYS:java.net.SocketPermission', '192.168.111.242', 'connect,accept,resolve');
这篇关于Oracle：发送JMS消息的Java存储过程的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
