现在的位置: 首页 > 综合 > 正文

使用JBoss和PostgreSQL—–快速开发EJB和J2EE Web Application

2013年08月24日 ⁄ 综合 ⁄ 共 15129字 ⁄ 字号 小 中 大 ⁄ 评论关闭
 作者：Han QW, 转载请指明出处 如有不当之处，敬请指出

先安装JSDK，再安装JBoss.
安装JSDK,必须获得一套对应于用户的操作系统的JDK，
我的安装的文件目录是
WINDOWS2000:    d:/s1studio_jdk/j2sdk1.4.1
linux：         /root/s1studio_jdk/j2sdk1.4.1
为了用EJB, 需要一个j2ee-1.3.jar或者j2ee-1.2.jar,
如果安装了Sun One Studio 或者 J2EE （www.sun.com ）这个文件已经有.
把这个文件放在classpath路径上.
或者使用jboss-j2ee.jar, 安装JBoss后在$JBoss/client中可找到. 
建议安装Sun One Studio, 用Sun One Studio编译JAVA源程序, 
不用设置classpath, 省去不少过程.

安装JBoss:
把JBoss的压缩包解开，放在任一目录上,
我的安装的文件目录是
/dose/jboss-3.0.4_tomcat-4.1.12 (REDHAT8.0)
E:/jboss-3.0.4_tomcat-4.1.12    (WINDOWS2000)
 WINDOWS2000, linux共用同一套JBoss.

配置JBoss：
启动JBoss需要执行一个脚本文件：
linux：run.sh
WINDOWS对应的是：run.bat

(1)
在JBoss/bin/run.bat (for Windows)开头插入一行
set JAVA_HOME = d:/s1studio_jdk/j2sdk1.4.1
在JBoss/bin/run.sh (for Linux)开头插入一行
JAVA_HOME="/root/s1studio_jdk/j2sdk1.4.1"

或者
(2)设置系统环境变量JAVA_HOME,指向JDK

运行JBoss, run.sh或者run.bat 
当看到启动JBoss的信息时，说明启动了.
服务器简单的测试：
JBoss默认的WEB端口为8080，我们可以在打开一个浏览器输入地址
http://localhost:8080/jmx-console
当在浏览器看到JBoss的信息时，说明安装配置JBoss成功了.

建立下面的目录和文件(注意大小写).

FIRST.EAR
|
|-----META-INF (application.xml)
|
|-----First.jar
|        |-----META-INF (ejb-jar.xml,jboss.xml)
|        `-----Dev
|               |-----First(FirstSession.java, FirstSessionHome.java, FirstSessionBean.java)
|               |-----Delegate(NewDelegate.java)
|               `-----Dao(MysqlDao.java)
|
`-----First.war(index.jsp)
        |
        `-----WEB-INF (jboss-web.xml, web.xml)
                |-----classes
                `-----lib

/*
**
**MysqlDao.java 
**
*/

  1. package Dev.Dao;
  3. import java.sql.Connection;
  4. import java.sql.SQLException;
  5. import java.sql.Statement;
  6. import java.sql.ResultSet;
  8. import javax.naming.InitialContext;
  9. import javax.sql.DataSource;
  12. public class MysqlDao {
  14.     public Connection getConnection() throws Exception {
  16.         InitialContext ctx = new InitialContext();
  18.         DataSource ds = (DataSource) ctx.lookup("java:/PostgresDS");
  21.         Connection conn = null;
  22.         Statement stmt = null;
  24.         try {
  25.             conn = ds.getConnection();
  27.         } catch (SQLException sqlEx) {
  28.             System.out.println("Error connect to pool.");
  29.         }
  31.         return conn;
  32.     }
  34.     public String getName(String id) throws Exception {
  36.         Connection conn = null;
  37.         Statement stmt = null;
  38.         ResultSet rs = null;
  39.         String name = "";
  41.         try {
  42.             conn = getConnection();
  43.             if ( conn !=null )System.out.println("Get conecttion. "+ conn.toString());
  44.             stmt = conn.createStatement();
  45.             if ( stmt !=null )System.out.println("Get Statement. "+ stmt.toString());
  46.             String sql = "SELECT * from users where id = '"+id+"'";
  47.             System.out.println("Sql from getId(): "+sql);
  48.            rs = stmt.executeQuery(sql);
  49.             if ( rs !=null )System.out.println("Get result. ");
  50.            if (rs.next()){
  51.             name = rs.getString("name");
  52.                }
  54.         } catch (Exception sqlEx) {
  55.         System.out.println("Error from getName().");
  56.                 System.out.println("Error from DAO.getName() :" + sqlEx.getMessage());
  57.         }finally {
  58.             if (conn != null) {
  59.                try { conn.close(); } catch (Exception sqlEx) { }
  60.             }
  61.         }
  62.         return name;
  63.     }
  65.     public String getCountry(String id) throws Exception {
  67.         Connection conn = null;
  68.         Statement stmt = null;
  69.         String name = "";
  71.         try {
  72.             conn = getConnection();
  73.             stmt = conn.createStatement();
  74.             String sql = "SELECT * from users where id = '"+id+"'";
  75.             System.out.println("Sql from getCountry(): "+sql);
  76.                java.sql.ResultSet rs = stmt.executeQuery(sql);
  77.                if (rs.next())
  78.             {
  79.                    name = rs.getString("Country");
  80.               }
  82.         } catch (SQLException sqlEx) {
  83.             System.out.println("Error from getCountry().");
  84.         }finally {
  85.             if (conn != null) {
  86.                try { conn.close(); } catch (Exception sqlEx) { }
  87.             }
  88.         }
  89.         return name;
  90.     }
  92. }

/*
**
**NewDelegate.java 
**
*/

  1. package Dev.Delegate;
  3. import java.lang.*;
  4. import Dev.First.*;
  7. public class NewDelegate {
  9.     Dev.First.FirstSession bean = null;
  10.     
  11.     public NewDelegate( ){
  12.        try {
  13.        javax.naming.InitialContext ctx = new javax.naming.InitialContext();
  14.        Object objref = ctx.lookup("ejb/FirstSession");
  15.        Dev.First.FirstSessionHome testBean = (Dev.First.FirstSessionHome)
  16.           javax.rmi.PortableRemoteObject.narrow
  17.           (objref,Dev.First.FirstSessionHome.class);
  18.        bean = testBean.create();
  19.        System.out.println("From JSP");
  20.     } catch (Exception NamingException) {
  21.            NamingException.printStackTrace();
  22.     }
  23.     }
  24.   
  25.     public String Welcome() {
  26.     String msg = "";
  27.     try {
  28.             msg = bean.Welcome();
  29.     } catch (Exception NamingException) { 
  30.            NamingException.printStackTrace();
  31.          }
  32.            return msg;
  33.     }
  34.     
  35.     public String getName(String id) {
  36.     String name = "";
  37.     try {
  38.             name = bean.getName(id);
  39.     } catch (Exception NamingException) { NamingException.printStackTrace();}
  40.         return name;
  41.     } 
  42.     
  43.     public String getCountry(String id) {
  44.     String country = "";
  45.     try {
  46.              country = bean.getCountry(id);
  47.     } catch (Exception NamingException) { NamingException.printStackTrace();}
  48.         return country;
  49.     }        
  50. }

/*
**
**FirstSession.java 
**
*/

  1. package Dev.First;
  3. import java.lang.*;
  4. import java.rmi.RemoteException;
  5. import javax.ejb.CreateException;
  6. import javax.ejb.EJBException;
  7. import javax.ejb.SessionBean;
  8. import javax.ejb.SessionContext;
  11. public interface FirstSession extends javax.ejb.EJBObject{
  13.          public String Welcome() throws java.rmi.RemoteException;
  14.          
  15.          public String getName(String id) throws java.rmi.RemoteException;
  16.          
  17.          public String getCountry(String id) throws java.rmi.RemoteException;
  19. }

/*
**
**FirstSessionHome.java 
**
*/

  1. package Dev.First;
  3. import java.lang.*;
  4. import java.rmi.RemoteException;
  5. import javax.ejb.CreateException;
  6. import javax.ejb.EJBException;
  7. import javax.ejb.SessionBean;
  8. import javax.ejb.SessionContext;
  11. public interface FirstSessionHome extends javax.ejb.EJBHome{
  13. public FirstSession create() throws javax.ejb.CreateException, java.rmi.RemoteException;
  15. }

/*
**
**FirstSessionBean.java 
**
*/

  1. package Dev.First;
  3. import java.rmi.RemoteException;
  4. import javax.ejb.CreateException;
  5. import javax.ejb.EJBException;
  6. import javax.ejb.SessionBean;
  7. import javax.ejb.SessionContext;
  10. public class FirstSessionBean implements SessionBean{
  12. public void ejbCreate() throws CreateException {
  14. }
  16. public String Welcome(){
  17.       String msg="Hello! This My Session Bean From Jboss.";
  18.       System.out.println(msg);
  19.       return msg;
  20. }
  22. public String getName(String id){
  23.       String name = "";
  24.       System.out.println("From bean before getName :"+ name);
  25.       try{
  26.       Dev.Dao.MysqlDao dao = new Dev.Dao.MysqlDao();
  27.       name = dao.getName(id);
  28.       System.out.println("From bean after getName :"+ name);
  29.       }catch(Exception e){ System.out.println(e.getMessage());}
  30.       return name;
  31. }
  33. public String getCountry(String id){
  34.       String country = "";
  35.       try{      
  36.       Dev.Dao.MysqlDao dao = new Dev.Dao.MysqlDao();
  37.       country = dao.getCountry(id);
  38.       }catch(Exception e){ }      
  39.       return country;
  40. }
  42. public void setSessionContext( SessionContext aContext ) throws EJBException {
  44. }
  46. public void ejbActivate() throws EJBException {
  48. }
  50. public void ejbPassivate() throws EJBException {
  52. }
  54. public void ejbRemove() throws EJBException {
  56. }
  58. }

/*Don't put the following lines into index.jsp
**
**index.jsp 
**
*/Don't put the above lines into index.jsp

  1. <%@page language="java" %>
  3. <%
  5.     String msg = "";
  6.     String msg1 = "";
  7.     Dev.Delegate.NewDelegate nn = new Dev.Delegate.NewDelegate();
  8.     if (request.getParameter("id") != null && 
  9.            request.getParameter("id") != ""&& 
  10.            !request.getParameter("id").equals("")){
  11.         String id = request.getParameter("id");
  12.         String name = "";
  13.         Dev.Dao.MysqlDao dao = new Dev.Dao.MysqlDao();
  14.         name = nn.getName(id);      //access database through session bean
  15.         //name = dao.getName(id);   //access database directly
  16.         if(name!= null && !name.equals("")){
  17.             msg1 ="Welcome  " + name +" !     You are from  "+ dao.getCountry(id)+ " .";
  18.         }else{
  19.             msg1 ="Please Check Your ID. : " + id;
  20.         }
  22.     }
  23.     msg = nn.Welcome() ;
  24. %>
  25. <html>
  27. <head>
  28. <title>Welcome</title>
  29. </head>
  31. <body bgcolor="#FFFFCC">
  32. <br> <%= msg %> <br>
  34. <FORM ACTION="index.jsp" method="post">
  36. <P>Your ID:
  37. <INPUT TYPE="TEXT" NAME="id" size = "10"></P>
  40. <P><INPUT TYPE="SUBMIT" NAME="SUBMIT"></P>
  41. </FORM>
  42. <br>
  43. <br>
  45. <%=(msg1 == "")? "":msg1 + "<br> <br> <br>Connect to Database OK." %>
  47. </body>
  48. </html>

<!--不要将此以下5行存入文件
**
**ejb-jar.xml
**
-->不要将此以上5行存入文件, 下同.

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN" 
  3. "http://java.sun.com/dtd/ejb-jar_2_0.dtd">
  5. <ejb-jar>
  7.  <description>First</description>
  8.  <display-name>First</display-name>
  10. <enterprise-beans>
  12. <!-- Session Beans -->
  13. <session id="MyFirstSession">
  14.      <display-name>My First Session Bean</display-name>
  15.      <ejb-name>FirstSession</ejb-name>
  16.      <home>Dev.First.FirstSessionHome</home>
  17.      <remote>Dev.First.FirstSession</remote>
  18.      <ejb-class>Dev.First.FirstSessionBean</ejb-class>
  19.      <session-type>Stateless</session-type>
  20.      <transaction-type>Container</transaction-type>
  21. </session>
  23. </enterprise-beans>
  25. <assembly-descriptor>
  27. </assembly-descriptor>
  29. </ejb-jar>

<!-- 
**
**jboss.xml
**
-->

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE jboss PUBLIC "-//JBoss//DTD JBOSS//EN" "http://www.jboss.org/j2ee/dtd/jboss.dtd">
  4. <jboss>
  6. <enterprise-beans>
  8. <session>
  9. <ejb-name>FirstSession</ejb-name>
  10. <jndi-name>ejbFirstSession</jndi-name>
  11. </session>
  13. </enterprise-beans>
  15. <resource-managers>
  16. </resource-managers>
  18. </jboss>

<!-- 
**
**jboss-web.xml
**
-->

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE jboss-web PUBLIC "-//JBoss//DTD Web Application 2.2//EN" 
  3. "http://www.jboss.org/j2ee/dtd/jboss-web.dtd">
  5. <jboss-web>
  8.     <resource-ref>
  9.         <res-ref-name>jdbcPostgresDS</res-ref-name>
  10.         <res-type>javax.sql.DataSource</res-type>
  11.         <jndi-name>java:/PostgresDS</jndi-name>
  12.     </resource-ref>
  14. </jboss-web>

<!-- 
**
**web.xml
**
-->

  1. <?xml version="1.0" encoding="ISO-8859-1"?>
  3. <!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.2//EN"
  4. "http://java.sun.com/j2ee/dtds/web-app_2_2.dtd">
  6. <web-app>
  8. <resource-ref>
  9.   <description>Postgresql driver</description>
  10.   <res-ref-name>jdbcPostgresDS</res-ref-name>
  11.   <res-type>javax.sql.DataSource</res-type>
  12.   <res-auth>Container</res-auth>
  13. </resource-ref>
  15. </web-app>

<!-- 
**
**application.xml
**
-->

  1. <?xml version="1.0" encoding="ISO-8859-1"?>
  3. <application>
  4. <display-name>First</display-name>
  5. <module>
  6. <web>
  7. <web-uri>First.war</web-uri>
  8. <context-root>/First</context-root>
  9. </web>
  10. </module>
  12. <module>
  13. <ejb>First.jar</ejb>
  14. </module>
  15. </application>

编译JAVA源程序,生成class文件.
进入JAVA源程序目录, 运行: 
javac -classpath  %classpath%;%jboss%/server/default/deploy/First.ear/First.jar *.java
或者
javac -classpath  %jboss%/server/default/deploy/First.ear/First.jar;%jboss%/client/jboss-j2ee.jar *.java

Copy 目录First.ear to jboss/server/default/deploy.
打开浏览器输入地址 http://localhost:8080/First

到此, 在浏览器看到:  Hello! This My Session Bean From Jboss. 
说明这个EJB工作了.

如果按按钮, 没反应或出错. 原因没安装配置数据库, 下面安装配置Postgres数据库

For Windows2000
下载 PgSQL731wina1.exe (http://www.postgresql.org),
Finally you will see the next line, you need enter the password for Administrator
最后你将看下一个行,你必须为用户Administrator输入password. 
********************
Enter password of user `./Administrator':123456
********************

记下此password, 我的口令是123456.

从开始菜单 > Programm > PostgresSQL > Adjust PostgresSQL Configuration file
它将在Wordpad中打开PostgresSQL Configuration文件, 找到下列行,

#
#    Connection Parameters
#
#tcpip_socket = false
#ssl = false

#max_connections = 32
#superuser_reserved_connections = 2

#port = 5432 

修改编辑:
#
#    Connection Parameters
#
tcpip_socket = true
#ssl = false

#max_connections = 32
#superuser_reserved_connections = 2

port = 5432 

接着，保存文件.

起动PostgresSQL服务器:
开始菜单>Programm>PostgresSQL>Utilies>Start PostgresSQL server
起动命令行:
开始菜单>Programm>PostgresSQL>Utilies>Command Shell

执行下列命令,准备数据,
Administrator@SAN /
$ dir

$ cd bin

$ createdb test

$ psql test

test=# create table users
test-# (name varchar(20),
test(# id varchar(20),
test(# country varchar(20));
test=# insert into users values ('Sam', '123', 'China');
test=# insert into users values ('Tom', '321', 'USA');
test=# insert into users values ('Sean', '231', 'France');

test=# select * from users;
 name | id  | country
------+-----+---------
 Sam  | 123 | China
 Tom  | 321 | USA
 Sean | 231 | France
(3 rows)

test=#

到此, 数据准备就绪.

For RedHat:
以root登陆, 执行下列命令,准备数据,
 
mkdir /usr/local/pgsql/data
chown postgres /usr/local/pgsql/data
su - postgres
/usr/local/pgsql/bin/initdb -D /usr/local/pgsql/data

Open and edit /usr/local/pgsql/data/pg_hba.conf

local      all                                          trust
host       all         127.0.0.1     255.255.255.255    trust

just delete #, and save.

[root@localhost root]# su - postgres
-bash-2.05b$ /usr/bin/postmaster -i -D /usr/local/pgsql/data >logfile 2>&1 &
-bash-2.05b$ /usr/bin/createdb test
-bash-2.05b$ /usr/local/pgsql/bin/psql test
test=#    .......the following same as Windows2000

到此, 数据准备就绪.

执行shutdown.bat or shutdown.sh, 停止Jboss Server.

找到JDBC drive.
为了在Jboss中使用连接池,需要拷贝jdbc drive 到Jboss/server/default/deploy ,  在linux 我们能找到/usr/share/pgsql/pgjdbc2.jar,在wondows2000,我们能找到PostgreSQL/usr/share/ postgresql/java/postgresql.jar
把其中之一复制到Jboss/server/default/deploy

配置Jboss

(1) 复制 $Jboss/examples/jca/postgres-service.xml 到 $Jboss/server/default/deploy/

(2) 打开编辑Jboss/server/default/deploy/postgres-service.xml

        <attribute name="JndiName">PostgresDS</attribute>
        <attribute name="ManagedConnectionFactoryProperties">
          <properties>
            <config-property name="ConnectionURL" type="java.lang.String">jdbc:postgresql://localhost/test</config-property>
            <config-property name="DriverClass" type="java.lang.String">org.postgresql.Driver</config-property>
            <!--set these only if you want only default logins, not through JAAS -->
            <config-property name="UserName" type="java.lang.String">Administrator</config-property>
            <config-property name="Password" type="java.lang.String">123456</config-property>
          </properties>

In my example, set Username  Administrator, password  123456 for windows 2000
        set Username  Postgres, no password  for Linux.
在我的例子中，
windows2000,   用户:Administrator，password:123456
Linux(RH8.0),  用户:Postgres, 没有password
因为PostgresSQL和windows2000使用不同的default用户名,所以在linux和window2000中这文件不同.当然，你可以加相同的PostgresSQL用户名和password在linux和window2000中, 这样这文件就相同了.

保存文件.

(3) 打开编辑 $Jboss/server/default/conf/standardjbosscmp-jdbc.xml
找到:
      <datasource>java:/DefaultDS</datasource>
      <datasource-mapping>Hypersonic SQL</datasource-mapping>
加入:
      <datasource>java:/PostgresDS</datasource>
      <datasource-mapping>Postgres</datasource-mapping> 
保存文件.

(4) open and edit $Jboss/server/default/conf/standardjaws.xml
找到:
   <datasource>java:/DefaultDS</datasource>
   <type-mapping>Hypersonic SQL</type-mapping>
   <debug>false</debug>
加入:
   <datasource>java:/PostgresDS</datasource>
   <type-mapping>Postgres</type-mapping>
   <debug>false</debug> 
保存文件.

现在重起JBoss.
打开浏览器输入地址 http://localhost:8080/First
输入ID,按按钮. 

返回
【上篇】
【下篇】

作者:

抱歉!评论已关闭.

返回首页

Copyright © 2013-2018 学步园  保留所有权利.
软文销售 QQ客服：2265327166 点击这里给我发消息（其他合作也可洽谈）
必威体育
必威电竞