当前位置: 代码迷 >> JBoss >> Myeclipse+Jboss+mysql JNDI调用疏失
  详细解决方案

Myeclipse+Jboss+mysql JNDI调用疏失

热度:227   发布时间:2016-05-11 05:56:11.0
Myeclipse+Jboss+mysql JNDI调用出错
package com.jms.jmsService;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Properties;

import org.jnp.interfaces.TimedSocketFactory;
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

public class ConnJms {

/**
 * 连接store空间(发送方)
 * @param args
 */
public static void main(String[] args) {
connJboss();//1
jbossClient();//2
}

//JBOSS JNDI连接方式

public static Context getJbossContext(){

final String INIT_FACTORY = "org.jnp.interfaces.NamingContextFactory";
final String SERVER_URL = "jnp://127.0.0.1:8080";
Context ctx = null;
try{

Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY,INIT_FACTORY);
env.put(Context.PROVIDER_URL,SERVER_URL);
ctx = new InitialContext(env);

}catch(Exception e){

e.printStackTrace();
}
return ctx;

}



public static void  jbossClient(){

final String INIT_FACTORY="org.jnp.interfaces.NamingContextFactory";
final String SERVER_URL="jnp://127.0.0.1:8080";
Hashtable map = new Hashtable();
map.put(Context.INITIAL_CONTEXT_FACTORY,INIT_FACTORY);
map.put(Context.PROVIDER_URL, SERVER_URL);

Properties properties = new Properties();   
   properties.setProperty(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");   
       properties.put(Context.URL_PKG_PREFIXES, "org.jboss.naming:org.jnp.interfaces");   
       properties.setProperty(Context.PROVIDER_URL,"localhost:1099");    
try {
Context ctx = new InitialContext(properties);
DataSource ds = (DataSource)ctx.lookup("java:/DefaultDS");
java.sql.Connection con = ds.getConnection();
Statement stat = con.createStatement();
ResultSet qu = stat.executeQuery("select * from mysql.user");
while(qu.next()){

System.out.println("------:"+qu.getString("User"));
}
} catch (NamingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
}


1:调用jbossClient()方法时报错:log4j:WARN No appenders could be found for logger (org.jnp.interfaces.TimedSocketFactory).
log4j:WARN Please initialize the log4j system properly.
javax.naming.NameNotFoundException: DefaultDS not bound
  相关解决方案
本站暂不开放注册!
内测阶段只得通过邀请码进行注册!
 
  • 最近登录:Sun Oct 22 10:53:41 CST 2017
  • 最近登录:Sun Oct 22 10:53:41 CST 2017
  • 最近登录:Sun Oct 22 10:53:41 CST 2017
  • 最近登录:Sun Oct 22 10:53:41 CST 2017
  • 最近登录:Sun Oct 22 10:53:41 CST 2017