@Test

    public void testSolrCloudAddDocument() throws Exception {

        // 第一步：把solrJ相关的jar包添加到工程中。

        // 第二步：创建一个SolrServer对象，需要使用CloudSolrServer子类。构造方法的参数是zookeeper的地址列表。

        //参数是zookeeper的地址列表，使用逗号分隔

        CloudSolrServer solrServer = new CloudSolrServer("192.168.25.132:2181,192.168.25.132:2182,192.168.25.132:2183");

        // 第三步：需要设置DefaultCollection属性。

        solrServer.setDefaultCollection("collection2");

        // 第四步：创建一SolrInputDocument对象。

        SolrInputDocument document = new SolrInputDocument();

        // 第五步：向文档对象中添加域

        document.addField("item_title", "测试商品");

        document.addField("item_price", "100");

        document.addField("id", "test001");

        // 第六步：把文档对象写入索引库。

        solrServer.add(document);

        // 第七步：提交。

        solrServer.commit();

    }

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans4.2.xsd

    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context4.2.xsd

    http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx4.2.xsd

    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util4.2.xsd">

    <!-- 单机版solr服务配置 -->

    <!-- <bean id="httpSolrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer">

        <constructor-arg name="baseURL" value="http://192.168.25.132:8080/solr"></constructor-arg>

    </bean> -->

    <!-- 集群版solr服务 -->

    <bean id="cloudSolrServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer">

        <constructor-arg name="zkHost" value="192.168.25.132:2181,192.168.25.132:2182,192.168.25.132:2183"></constructor-arg>

        <property name="defaultCollection" value="collection2"></property>

    </bean>

</beans>

public class GlobalExceptionReslover implements HandlerExceptionResolver {

    Logger logger = LoggerFactory.getLogger(GlobalExceptionReslover.class);

    @Override

    public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler,

            Exception ex) {

        //写日志文件

        logger.error("系统发生异常", ex);

        //发邮件、发短信

        //Jmail：可以查找相关的资料

        //需要在购买短信。调用第三方接口即可。

        //展示错误页面

        ModelAndView modelAndView = new ModelAndView();

        modelAndView.addObject("message", "系统发生异常，请稍后重试");

        modelAndView.setViewName("error/exception");

        return modelAndView;

    }

}

@Test

    public void testQueueProducer() throws Exception {

        // 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。

        //brokerURL服务器的ip及端口号

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");

        // 第二步：使用ConnectionFactory对象创建一个Connection对象。

        Connection connection = connectionFactory.createConnection();

        // 第三步：开启连接，调用Connection对象的start方法。

        connection.start();

        // 第四步：使用Connection对象创建一个Session对象。

        //第一个参数：是否开启事务。true：开启事务，第二个参数忽略。

        //第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。

        //参数：队列的名称。

        Queue queue = session.createQueue("test-queue");

        // 第六步：使用Session对象创建一个Producer对象。

        MessageProducer producer = session.createProducer(queue);

        // 第七步：创建一个Message对象，创建一个TextMessage对象。

        /*TextMessage message = new ActiveMQTextMessage();

        message.setText("hello activeMq,this is my first test.");*/

        TextMessage textMessage = session.createTextMessage("hello activeMq,this is my first test.");

        // 第八步：使用Producer对象发送消息。

        producer.send(textMessage);

        // 第九步：关闭资源。

        producer.close();

        session.close();

        connection.close();

    }

@Test

    public void testQueueConsumer() throws Exception {

        // 第一步：创建一个ConnectionFactory对象。

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");

        // 第二步：从ConnectionFactory对象中获得一个Connection对象。

        Connection connection = connectionFactory.createConnection();

        // 第三步：开启连接。调用Connection对象的start方法。

        connection.start();

        // 第四步：使用Connection对象创建一个Session对象。

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 第五步：使用Session对象创建一个Destination对象。和发送端保持一致queue，并且队列的名称一致。

        Queue queue = session.createQueue("test-queue");

        // 第六步：使用Session对象创建一个Consumer对象。

        MessageConsumer consumer = session.createConsumer(queue);

        // 第七步：接收消息。

        consumer.setMessageListener(new MessageListener() {

            @Override

            public void onMessage(Message message) {

                try {

                    TextMessage textMessage = (TextMessage) message;

                    String text = null;

                    //取消息的内容

                    text = textMessage.getText();

                    // 第八步：打印消息。

                    System.out.println(text);

                } catch (JMSException e) {

                    e.printStackTrace();

                }

            }

        });

        //等待键盘输入

        System.in.read();

        // 第九步：关闭资源

        consumer.close();

        session.close();

        connection.close();

    }

@Test

    public void testTopicProducer() throws Exception {

        // 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。

        // brokerURL服务器的ip及端口号

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");

        // 第二步：使用ConnectionFactory对象创建一个Connection对象。

        Connection connection = connectionFactory.createConnection();

        // 第三步：开启连接，调用Connection对象的start方法。

        connection.start();

        // 第四步：使用Connection对象创建一个Session对象。

        // 第一个参数：是否开启事务。true：开启事务，第二个参数忽略。

        // 第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个topic对象。

        // 参数：话题的名称。

        Topic topic = session.createTopic("test-topic");

        // 第六步：使用Session对象创建一个Producer对象。

        MessageProducer producer = session.createProducer(topic);

        // 第七步：创建一个Message对象，创建一个TextMessage对象。

        /*

         * TextMessage message = new ActiveMQTextMessage(); message.setText(

         * "hello activeMq,this is my first test.");

         */

        TextMessage textMessage = session.createTextMessage("hello activeMq,this is my topic test");

        // 第八步：使用Producer对象发送消息。

        producer.send(textMessage);

        // 第九步：关闭资源。

        producer.close();

        session.close();

        connection.close();

    }

@Test

    public void testTopicConsumer() throws Exception {

        // 第一步：创建一个ConnectionFactory对象。

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");

        // 第二步：从ConnectionFactory对象中获得一个Connection对象。

        Connection connection = connectionFactory.createConnection();

        // 第三步：开启连接。调用Connection对象的start方法。

        connection.start();

        // 第四步：使用Connection对象创建一个Session对象。

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且话题的名称一致。

        Topic topic = session.createTopic("test-topic");

        // 第六步：使用Session对象创建一个Consumer对象。

        MessageConsumer consumer = session.createConsumer(topic);

        // 第七步：接收消息。

        consumer.setMessageListener(new MessageListener() {

            @Override

            public void onMessage(Message message) {

                try {

                    TextMessage textMessage = (TextMessage) message;

                    String text = null;

                    // 取消息的内容

                    text = textMessage.getText();

                    // 第八步：打印消息。

                    System.out.println(text);

                } catch (JMSException e) {

                    e.printStackTrace();

                }

            }

        });

        System.out.println("topic的消费端03。。。。。");

        // 等待键盘输入

        System.in.read();

        // 第九步：关闭资源

        consumer.close();

        session.close();

        connection.close();

    }