public class OnlinePreviewController {
	@GetMapping( "/onlinePreview")
    // 添加 keyword 接收高亮关键字
    public String onlinePreview(String url, String keyword, Model model, HttpServletRequest req) {
       // *************
        model.addAttribute("file", fileAttribute);
        // 高亮关键字返回给前端
        model.addAttribute("keyword", keyword);
       // *************
        return filePreview.filePreviewHandle(fileUrl, model, fileAttribute);
    }
}

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.boot.SpringApplication;

public class MessagingApp {

    public static void main(String[] args) {
        String serviceUrl = "tcp://192.168.14.103:1883";
        String userName = "test-mqtt:maxzhao";
        String password = "maxzhao";
        String clientId = "maxzhao_amdin";
        // 创建对象
        MessagingApp mqttClient = new MessagingApp();
        // mqttClient类初始化
        mqttClient.init(serviceUrl, userName, password, clientId);
        // 订阅主题
        mqttClient.subscribeTopic("/key1", 0);
        // 发布消息
        for (int i = 0; i < 50; i++) {
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // Do nothing
            }
            mqttClient.publishMessage("/key1", "消息 " + i, 1);
        }
        // 取消订阅
        mqttClient.cleanTopic("/key");
        SpringApplication.run(MessagingApp.class, args);
    }

    /**
     * MQTT连接对象 对连接进行设置
     */
    private MqttClient mqttClient;


    /**
     * 类初始化，建立mqttClient连接
     */
    public void init(String serviceUrl, String userName, String password, String clientId) {
        //初始化连接对象
        /**
         * mqtt客户端对象
         */
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        //初始化mqttClient
        if (mqttConnectOptions != null) {
            // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
            mqttConnectOptions.setCleanSession(true);
            //设置超时时间 单位为秒
            mqttConnectOptions.setConnectionTimeout(30);
            mqttConnectOptions.setUserName(userName);
            mqttConnectOptions.setPassword(password.toCharArray());
            //设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制
            mqttConnectOptions.setKeepAliveInterval(45);
            MemoryPersistence memoryPersistence = new MemoryPersistence();
            if (mqttConnectOptions != null && clientId != null) {
                try {
                    mqttClient = new MqttClient(serviceUrl, clientId, memoryPersistence);
                } catch (MqttException e) {
                    e.printStackTrace();
                }
            } else {
                System.out.println("mqttConnectOptions == null || clientId == null");
            }
        } else {
            System.out.println("mqttConnectOptions == null");
        }
        System.out.println("MqttClient是否连接？" + mqttClient.isConnected());
        if (mqttClient != null) {
            //创建回调函数对象,用来接收已经订阅的消息
            mqttClient.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable throwable) {

                }

                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Client 接收消息主题 : " + topic);
                    System.out.println("Client 接收消息Qos : " + message.getQos());
                    System.out.println("Client 接收消息内容 : " + new String(message.getPayload()));
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

                }
            });
            System.out.println("创建连接......");
            try {
                mqttClient.connect(mqttConnectOptions);
            } catch (MqttException e) {
                e.printStackTrace();
            }
        } else {
            System.out.println("mqttClient对象为空，连接失败...");
        }
        System.out.println("mqttClient是否连接？" + mqttClient.isConnected());
    }

    /**
     * 订阅主题
     *
     * @param topic topic
     * @param qos   消息质量
     */
    public void subscribeTopic(String topic, int qos) {
        if (mqttClient != null && mqttClient.isConnected() && topic != null) {
            try {
                mqttClient.subscribe(topic, qos);
            } catch (MqttException e) {
                e.printStackTrace();
            }
        } else {
            System.out.println("订阅失败 mqttClient 无法连接");
        }
    }

    /**
     * 取消订阅主题
     *
     * @param topic topic
     */
    public void cleanTopic(String topic) {
        if (mqttClient != null && mqttClient.isConnected()) {
            try {
                mqttClient.unsubscribe(topic);
            } catch (MqttException e) {
                e.printStackTrace();
            }
        } else {
            System.out.println("取消订阅失败 mqttClient 无法连接");
        }
    }

    /**
     * 发布消息
     *
     * @param topic          topic
     * @param messageContent 消息内容
     * @param qos            消息质量
     */
    public void publishMessage(String topic, String messageContent, int qos) {
        // 判断是否连接
        if (mqttClient != null && mqttClient.isConnected()) {
            System.out.println("发布消息.......");
            System.out.println("发布消息人的clientId：" + mqttClient.getClientId());
            MqttMessage mqttMessage = new MqttMessage();
            mqttMessage.setQos(qos);
            mqttMessage.setPayload(messageContent.getBytes());
            MqttTopic mqttTopic = mqttClient.getTopic(topic);
            if (mqttTopic != null) {
                try {
                    MqttDeliveryToken publish = mqttTopic.publish(mqttMessage);
                    if (!publish.isComplete()) {
                        System.out.println("消息发布成功！");
                    }
                } catch (MqttException e) {
                    e.printStackTrace();
                }
            } else {
                System.out.println("mqttTopic == null");
            }
        } else {
            System.out.println("mqttClient == null || mqttClient.isConnected() == false");
        }
    }
}

@SpringBootApplication
public class ProviderApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext applicationContext = SpringApplication.run(ProviderApplication.class, args);
        String userName = applicationContext.getEnvironment().getProperty("user.name");
        String userAge = applicationContext.getEnvironment().getProperty("user.age");
        System.err.println("user name :"+userName+"; age: "+userAge);
    }
}

@SpringBootApplication
public class ProviderApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext applicationContext = SpringApplication.run(ProviderApplication.class, args);
        while(true) {
            //当动态配置刷新时，会更新到 Enviroment中，因此这里每隔一秒中从Enviroment中获取配置
            String userName = applicationContext.getEnvironment().getProperty("user.name");
            String userAge = applicationContext.getEnvironment().getProperty("user.age");
            System.err.println("user name :" + userName + "; age: " + userAge);
            TimeUnit.SECONDS.sleep(1);
        }
    }
}

@SpringBootApplication
public class ProviderApplication {

    public static void main(String[] args) {
        ConfigurableApplicationContext applicationContext = SpringApplication.run(ProviderApplication.class, args);
        while(true) {
            String userName = applicationContext.getEnvironment().getProperty("user.name");
            String userAge = applicationContext.getEnvironment().getProperty("user.age");
            //获取当前部署的环境
            String currentEnv = applicationContext.getEnvironment().getProperty("current.env");
            System.err.println("in "+currentEnv+" enviroment; "+"user name :" + userName + "; age: " + userAge);
            TimeUnit.SECONDS.sleep(1);
        }
    }
}

/**
 * Author:lvfang
 *
 * Created by mis on 2017/5/24.
 */
public class SolrTest {

    public final String baseURL = "http://192.168.22.128:8081/solr";

    public HttpSolrServer server=null;

    /**
    * 创建SolrServer对象
    * 该对象有两个可以使用，都是线程安全的 1、CommonsHttpSolrServer：启动web服务器使用的，通过http请求的 2、
     * EmbeddedSolrServer：内嵌式的，导入solr的jar包就可以使用了 3、solr
     * 4.0之后好像添加了不少东西，其中CommonsHttpSolrServer这个类改名为HttpSolrClient
     * 
    */
    @Before
    public void init() throws Exception{
        //new HttpSolrClient.Builder(BASE_URL).build()
        server=new HttpSolrServer(baseURL);
    }

    /**
     * 基于索引名添加
     * @throws Exception
     */
    @Test
    public void testAdd() throws Exception{
        Car car1 = new Car("Audi000A4001","奥迪A4L",295000,"/images/001.jpg");
        //Car car1 = new Car("BMW0000B5001","宝马5系",436800,"/images/002.jpg");
        SolrInputDocument doc1 = new SolrInputDocument();
        doc1.addField("id",car1.getId());
        doc1.addField("name",car1.getName());
        doc1.addField("price",car1.getPrice());
        doc1.addField("url",car1.getUrl());
		// 这里也可以传递集合 List<SolrInputDocument> 
        server.add(doc1);
        UpdateResponse rspcommit = server.commit();
        // 操作完成 0
        rspcommit.getStatus();
        System.out.println("操作完成！！！");
    }

    /**
     * 基于bean添加（注意，这里bean的属性要添加solr的注解@Field）
     * @throws Exception
     */
    @Test
    public void testAddBean() throws Exception{
        Car car1 = new Car("BMW0000B5001","宝马5系",436800,"/images/002.jpg");
        server.addBean(car1);
        // 添加集合  List<Car>
        // server.addBeans(list);
        server.commit();
        System.out.println("操作完成！！！");
    } 

    /**
     * Document结果转换bean
     * @throws Exception
     */
    @Test
    public void change() throws Exception {
        SolrDocument doc1 = new SolrDocument();
        doc1.addField("id","Siju0032SJ0C8001");
        doc1.addField("name","世爵C8");
        doc1.addField("price",1370000);
        doc1.addField("url","/images/005.jps");

        Car car = server.getBinder().getBean(Car.class,doc1);
        System.out.println(car);
        System.out.println("操作完成！！！");
    }

    /**
     * 删除
     * @throws Exception
     */
    @Test
    public void testDel() throws Exception{
        //server.deleteById("1");
        server.deleteByQuery("*:*");
        server.commit();
        System.out.println("操作完成！！！");
    }

    /**
     * 修改（可以理解为重新添加，）
     * @throws Exception
     */
    @Test
    public void testUpdate() throws Exception {
        SolrInputDocument doc1 = new SolrInputDocument();
        doc1.addField("id","1");
        doc1.addField("title","lisi");
        server.add(doc1);

        server.commit();
        System.out.println("操作完成！！！");
    }

    /**
     * 查询
     * @throws Exception
     */
    @Test
    public void testQuery() throws Exception {
        SolrQuery query = new SolrQuery("name:*");
        //SolrQuery query = new SolrQuery("*:*");
        query.setStart(0);//起始页
        query.setRows(3);//每页显示数量

        QueryResponse rsp = server.query( query );
        SolrDocumentList results = rsp.getResults();
        System.out.println("总记录数为：" + results.getNumFound());//查询总条数

        for(SolrDocument document : results){
            System.out.println(document.get("id") + " " + document.get("name") + " " + document.get("price"));
        }
    }


    /**
     * 多条件查询
     * @throws Exception
     */
    @Test
    public void testQueryMulti() throws Exception {
        ModifiableSolrParams params = new ModifiableSolrParams();

        //组织查询条件
        params.set("q","*:*");
        params.set("start",0);
        params.set("rows",10);
        params.set("sort","price desc");

        QueryResponse response = server.query(params);
        SolrDocumentList list = response.getResults();

        for(SolrDocument doc : list){
            System.out.println(server.getBinder().getBean(Car.class,doc));
        }
    }

    /**
     *
     * @throws Exception
     */
    @Test
    public void testQueryCase() throws  Exception{
        SolrQuery params = new SolrQuery();

        //AND OR NOT条件
//      params.set("q","name:35系 AND price:152880.0");
//      params.set("q","name:5系 OR price:152880.0");
//      params.set("q","name:5系 NOT price:152880.0");

        //To 条件  min <= price <= max
//      params.set("q","price:[130000 TO 160000]");

        //To 条件  min < price < max
//      params.set("q","price:{130000 TO 160000}");
//      params.addFacetQuery("name:宝马");

        //显示设置
//      params.setHighlight(true);
//      params.addHighlightField("name");
//      params.setHighlightSimplePre("<font color = 'red'>");
//      params.setHighlightSimplePost("</font>");
//      params.setHighlightSnippets(1);
//      params.setHighlightFragsize(100);


//      params.set("start",0);
//      params.set("rows",10);
        params.set("sort","price desc");
        QueryResponse response = server.query(params);
        SolrDocumentList list = response.getResults();

        for(SolrDocument doc : list){
            System.out.println(server.getBinder().getBean(Car.class,doc));
        }
    }

    @After
    public void destroy(){
        server.shutdown();
        server = null;
    }
}