EJB+JBoss集群例子

File: Session.java   
package org.jboss.tutorial.clustering.bean;   
  
public interface Session   
{   
   void test();   
}   
  
  
File: SessionBean.java   
package org.jboss.tutorial.clustering.bean;   
  
import javax.ejb.Stateless;   
import javax.ejb.Remote;   
import org.jboss.annotation.ejb.Clustered;   
import org.jboss.annotation.ejb.Clustered;   
  
@Stateless  
@Clustered  
@Remote(Session.class)   
public class SessionBean implements Session   
{   
   public void test()   
   {   
      System.out.println("hello!!!");   
   }   
}   
  
  
File: StatefulBean.java   
package org.jboss.tutorial.clustering.bean;   
  
import javax.ejb.Stateful;   
import javax.ejb.Remote;   
import org.jboss.annotation.ejb.Clustered;   
  
@Stateful  
@Clustered  
@Remote(StatefulRemote.class)   
public class StatefulBean implements java.io.Serializable, StatefulRemote   
{   
   private int state = 0;   
  
   public void increment()   
   {   
      System.out.println("counter: " + (++state));   
   }   
      
   public String toString()   
   {   
      return super.toString() + " state-(" + state + ")";   
   }   
}   
  
  
File: StatefulRemote.java   
  
package org.jboss.tutorial.clustering.bean;   
  
public interface StatefulRemote   
{   
   void increment();   
}   
  
  
File: StatefulRun.java   
package org.jboss.tutorial.clustering.client;   
  
import org.jboss.tutorial.clustering.bean.StatefulRemote;   
  
import javax.naming.InitialContext;   
  
public class StatefulRun   
{   
   public static void main(String[] args) throws Exception   
   {   
      InitialContext ctx = new InitialContext();   
      StatefulRemote remote = (StatefulRemote) ctx.lookup("StatefulBean/remote");   
      while (true)   
      {   
         remote.increment();   
         Thread.sleep(10000);   
      }   
   }   
}   
  
  
File: StatelessRun.java   
  
package org.jboss.tutorial.clustering.client;   
  
import org.jboss.tutorial.clustering.bean.Session;   
  
import javax.naming.InitialContext;   
  
public class StatelessRun   
{   
   public static void main(String[] args) throws Exception   
   {   
      InitialContext ctx = new InitialContext();   
      Session remote = (Session) ctx.lookup("SessionBean/remote");   
      while (true)   
      {   
         remote.test();   
         Thread.sleep(1000);   
      }   
   }   
}