ActiveMQ数据访问减压

【实例简介】：短信发送 时：当客户大批量的发送短信时，一次给上万人发送短信
【实例截图】
【核心代码】public class NxtReceiveMqBaseOld {
               private static Connection connection;
               private static ConnectionFactory connectionFactory;
               private static Session session;
               private static String brokerURL="";
               private static Destination destination;
              
               public void init(){
                   try {
                  connectionFactory=new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, brokerURL);
  ((ActiveMQConnectionFactory)connectionFactory).setOptimizeAcknowledge(false);
                  connection=connectionFactory.createConnection();
                  ((ActiveMQConnection)connection).setOptimizeAcknowledge(false);
  connection.start();
  session=connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                   } catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
               }
               public void unicode(){
              BrokerService broker=new BrokerService();
              try {
              
broker.addConnector(brokerURL);
broker.start();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
               }
               private static  MessageConsumer consumer;
               public boolean receveiMessage(String topic,String brokerURL, boolean send){
              try{
              this.brokerURL=brokerURL;
              init();
              destination=session.createTopic(topic);
              consumer=session.createConsumer(destination);
              consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message data) {
 try {
TextMessage textMessage=(TextMessage)data;
String wang=textMessage.getText();
System.out.println(wang);
ReceiveTopic topic=new ReceiveTopic();
topic.result(wang);
} catch (JMSException e) {

e.printStackTrace();

}
 
}
});
              }catch(Exception e){
              send=false;
              }
              return send;
               }
               public static void main(String[] args) throws JMSException {
              boolean send=true;
              NxtReceiveMqBaseOld nxt=new NxtReceiveMqBaseOld();
              send=nxt.receveiMessage("FirstTopic", "tcp://192.168.0.239:61616",send);
              while(!send){
              System.out.println("重新发送");
              send=nxt.receveiMessage("FirstTopic", "tcp://192.168.0.239:61616",send);
              }
}
}