JMS 收发消息代码

我是做性能测试的,最近接了一个项目,测试我们这边将要使用的weblogic的JMS中间件,想测一下JMS的收发效率,目标是每秒2.5-3W笔,最TM无语的是还让我们这些做测试的编程小白自己弄环境和写代码.无奈把百度来的代码东拼西凑写好了收发代码,测试了最多速度只有1W笔/秒。
代码见下。
求大神指教下代码还要怎么优化下,有错误的话请指教.
如果你有更好的测试方案,麻烦指教下.
不胜感激！

Sender代码

import java.util.Collections;
import java.util.LinkedList;
import java.util.List;
import java.util.Properties;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.MessageConsumer;
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 JMSrecevier.MyTherad;

public class TestMessage {

    private int currentNum = 0; 
    
    private Session currentObj;
     
    private List<Session> pool;
     
    private Connection conn = null;



    public void sendMessage() throws JMSException, NamingException{
    
    pool = Collections.synchronizedList(new LinkedList<Session>());
        
    try {
    
   
        final String CONNECTION_FACTORY_JNDI = "ConnectionFactory-1" ; 
       
        Context ctx = getInitialContext();
        
        ConnectionFactory connFactory = (ConnectionFactory)ctx.lookup(CONNECTION_FACTORY_JNDI);
       
        
       
        Destination dest = (Destination)ctx.lookup("Queue-1");
        
        conn = connFactory.createConnection();
       
        conn.start();
        
      		for(int i=0;i<2000;i++)
      		{
      			new Thread(new MyTherad(dest)).start();
      		}
    
      			//conn.close();
		    } catch (Exception e) {
		    	e.printStackTrace();
		    }
        
    }     
        
    
    
public class MyTherad  implements Runnable
{
	private Destination dest;
	public MyTherad(Destination dest)
	{
		this.dest=dest;
	}
	@Override
	public void run() {
	try {
			while(true)
			{
				Session	session=getSession();
				MessageProducer sender = session.createProducer(dest);
				sender.setDeliveryMode(DeliveryMode.PERSISTENT);
		        //sender.setTimeToLive(20000);
		        
		        MapMessage msg = session.createMapMessage();
		        
		        msg.setStringProperty("message","hello");
		        
		        sender.send(msg);
				returnSession(session);
				//System.out.println(currentNum);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

	}


}



    
    private Context getInitialContext(){
        Context ctx = null;
        Properties props = new Properties();
        props.put( Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
        props.put( Context.PROVIDER_URL, "t3://10.243.32.44:8001");    
        try {
             ctx = new InitialContext(props);
        } catch (NamingException e) {
            e.printStackTrace();
        }
        
        return ctx;
    }
    
    
    public static void main(String args[]){
    	TestMessage mp = new TestMessage();
        try {
            mp.sendMessage();
        } catch (JMSException e) {
            e.printStackTrace();
        } catch (NamingException e) {
            e.printStackTrace();
        }
    }
    
    
    public synchronized Session getSession() throws Exception {
        
        if (pool.size() == 0 && currentNum < 2000) {
         
        
         
        currentObj = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
         
        pool.add(currentObj);
        System.out.println(pool.size());
        currentNum++;
         
        } else
         
        if (pool.size() == 0 && currentNum >= 2000) {
         
       
         
        while (pool.size() == 0) {
        }
        currentObj = (Session)pool.remove(0);
         
        } else {
         
        
         
        currentObj = (Session)pool.remove(0);
         
        }
         
        return currentObj;
         
        }
      
        public void returnSession(Session session) {
         
        pool.add(session);
         
        }
        
        public Connection getConn() {
         
        return conn;
         
        } 

}

Receiver代码

package JMS;

import java.util.Collections;
import java.util.LinkedList;
import java.util.List;
import java.util.Properties;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;


public class JMSReceiver {
	private int currentNum = 0; // 该对象池当前已创建的对象数目
    
    private Session currentObj;// 该对象池当前可以借出的对象
     
    private List<Session> pool;// 用于存放对象的池
     
    private Connection conn = null;
	 public void receiveMessage() throws JMSException, NamingException{
		 pool = Collections.synchronizedList(new LinkedList<Session>());
	     
		    try {
		        final String CONNECTION_FACTORY_JNDI = "ConnectionFactoryQueue" ; 
		        //
		        Context ctx = getInitialContext();
		        //
		        ConnectionFactory connFactory = (ConnectionFactory)ctx.lookup(CONNECTION_FACTORY_JNDI);
		        //
		        Destination dest = (Destination)ctx.lookup("QueueHezh");
		        
		        conn = connFactory.createConnection();
		        //
		        conn.start();
		       
		        	for(int i=0;i<2000;i++){
		        		new Thread(new MyTherad(dest)).start();
		        	}
		        
		        //conn.close();
            		    } catch (Exception e) {
		     e.printStackTrace();
		    }
		     
		    }
    public class MyTherad  implements Runnable{
    	private Destination dest;
    	public MyTherad(Destination dest){
    		this.dest=dest;
    	}
		@Override
		public void run() {
			try {
				while(true){
			Session	session=getSession();
			MessageConsumer receiver = session.createConsumer(dest);
	        MapMessage msg = (MapMessage)receiver.receive();
	        //System.out.println(msg);
	        returnSession(session);
	        System.out.println(currentNum);
				}
			} catch (Exception e) {
				e.printStackTrace();
			}

		}

    
    }
    private Context getInitialContext(){
        Context ctx = null;
        Properties props = new Properties();
        props.put( Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
        props.put( Context.PROVIDER_URL, "t3://192.168.43.170:7001");    
        try {
             ctx = new InitialContext(props);
        } catch (NamingException e) {
            e.printStackTrace();
        }
        
        return ctx;
    }
    
    public static void main(String args[]){
    
    	JMSReceiver s = new JMSReceiver();
        try {
            s.receiveMessage();
        } catch (JMSException e) {
            e.printStackTrace();
        } catch (NamingException e) {
            e.printStackTrace();
        }
    }
    /**
    
     * session连接池
     
     * @author Li Bangsen 2012-12-19 下午02:34:06
     
     */
     
    public synchronized Session getSession() throws Exception {
     
    if (pool.size() == 0 && currentNum < 100) {
     
    // 如果当前池中无对象可用，而且已创建的对象数目小于所限制的最大值，创建一个新的对象
     
    currentObj = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
     
    pool.add(currentObj);
    System.out.println(pool.size());
    currentNum++;
     
    } else
     
    if (pool.size() == 0 && currentNum >= 100) {
     
    // 如果当前池中无对象可用，而且所创建的对象数目已达到所限制的最大值, 就只能等待其它线程返回对象到池中
     
    while (pool.size() == 0) {
    }
    currentObj = (Session)pool.remove(0);
     
    } else {
     
    // 如果当前池中有可用的对象，就直接从池中取出对象
     
    currentObj = (Session)pool.remove(0);
     
    }
     
    return currentObj;
     
    }
  
    public void returnSession(Session session) {
     
    pool.add(session);
     
    }
    
    public Connection getConn() {
     
    return conn;
     
    } 
    }