zoukankan      html  css  js  c++  java
  • ssm整合redis

    # 1.ssm整合redis

    1. 导入依赖
    2. 编写配置文件,修改配置文件的ip,和端口

    ![1586566250656](assets/1586566250656.png)

    3. 让spring的配置文件加载redis的配置

    ![1586566304923](assets/1586566304923.png)

    4. 就可以直接使用redis了.再代码的任意位置,注入RedisTemplate就ok

    ![1586566355669](assets/1586566355669.png)

    # 2.redis作为缓存思路

    1. 先从redis中查询有没有数据
    2. 如果redis中没有热点数据,就从mysql中查询,查询出来之后,往redis保存一份,返回
    3. 如果redis中有数据,直接返回就ok

    ```java
    //redis优化:
    //1.先从redis中看看有没有
    List<Plan> redisPlans = redisTemplate.opsForList().range("zhunneng_plans", 0, -1);
    if(redisPlans ==null || redisPlans.size()==0) {
    //redis中没有该数据,从mysql中查询,且放入redis一份,返回给前台
    PageInfo<Plan> info = planService.findAll(pageNum,pageSize);
    System.out.println("从mysql中查询了数据!!!!!!!!!!!!!!!!!!!!!");
    //往redis中存一份
    redisTemplate.opsForList().rightPushAll("zhunneng_plans", info.getList().toArray());
    model.addAttribute("info", info);

    }else {
    // redis数据不为空
    System.out.println("从redis中查询了数据!!!!!!!!!!!!!!!!!!!!!");
    model.addAttribute("info", new PageInfo<>(redisPlans));
    }

    ```

    注意:**别忘记启动redis服务**

    # 3.ssm中整合kafka(生产者)

    1. 导入依赖(用提供的pom中的依赖)
    2. 编写配置文件producer.xml,修改主题,ip,端口
    3. 让spring来加载producer.xml

    ![1586566660213](assets/1586566660213.png)

    4. 就可以在需要的位置注入Kafkatemplate来使用了

    ![1586566705909](assets/1586566705909.png)

    ![1586566734172](assets/1586566734172.png)

    # 4.ssm中整合kafka(消费者)

    1. 导入依赖
    2. 编写配置文件(consumer.xml),修改配置文件的ip,主题,监听器的全限定类名
    3. 让spring配置文件加载consumer.xml

    ![1586566944960](assets/1586566944960.png)

    4. 可以根据配置文件,编写监听器

    ![1586566988563](assets/1586566988563.png)

    ![1586567043655](assets/1586567043655.png)

    5. 如果要测试发,收消息,一定要在kafka的服务中启动kafka(先启动zk),为了测试服务器上能否收到消息,还要启动一个消费者,来监听消息

    # 5.ssm中整合es

    1. 导入依赖
    2. 编写配置文件,修改ip和端口,指定仓库接口的包扫描位置

    ![1586567279652](assets/1586567279652.png)

    3. 根据配置文件的包的位置,就可以创建接口了(继承:ElasticsearchRepository),此时这个接口就具备了CRUD的功能

    ![1586567334759](assets/1586567334759.png)

    4. 在实体类中指定**索引库的名称**(**必须小写字母**),和表名,指定主键对应的id,指定某个搜索字段的存储属性

    ![1586567622992](assets/1586567622992.png)

    5. 紧接着我们就写一个测试类,可以注入XXXRepository这个接口,实现数据的导入,因为我们的es索引库中没数据,想要搜索到数据,必须得从mysql中查询出数据,然后导入到es索引库,能够保证mysql的数据,和es索引库的数据的一致性

    ![1586568473232](assets/1586568473232.png)

    6. 我们就可以直接调用咱们的HLUtils工具类,实现高亮了

    ```java
    PageInfo<Plan> info = (PageInfo<Plan>) HLUtils.findByHighLight(elasticsearchTemplate, Plan.class, pageNum, pageSize, new String[] {"manager","name","content"}, "id", keyword);
    ```

    # 6.把项目部署到Linux中

    1. 修改db.properties

    ![1586568785480](assets/1586568785480.png)

    注意:**linux中不识别 只识别 / **

    2. 把windows上mysql的相关表导入到linux的mysql里

    ![1586569199574](assets/1586569199574.png)

    3. 接着就可以打包了

    ![1586569270229](assets/1586569270229.png)

    4. 到日志中找到对应的war

    ![1586569331341](assets/1586569331341.png)

    5. 找到这个位置的war,复制到桌面,重命名叫ROOT.war

    ![1586569407080](assets/1586569407080.png)

    6. 打开CRT ,上传ROOT.war 到tomcat下的webapps下,注意:**上传之前一定要先关闭tomcat,然后删除ROOT目录**
    7. 动态查看日志

    ![1586569634157](assets/1586569634157.png)

    8. 启动tomcat(**注意:启动tomcat之前,保证redis,es,kafka服务的启动**)

    ![1586569669286](assets/1586569669286.png)

    9. 在浏览器中访问该项目

    ![1586569899316](assets/1586569899316.png)

    10. 模拟一个域名来访问,到:C:windowssystem32driversetc

    找hosts文件.修改hosts文件里的内容:

    ![1586572065292](assets/1586572065292.png)

    保存成功之后,就可以直接访问了!!

    ![1586572210724](assets/1586572210724.png)

    # 7.如何才能保证es索引库,redis数据库,mysql数据库中的数据一致性?

    增加,修改,删除的时候,不仅要对mysql做操作,还要利用kafka发送消息,接收消息,让监听器接收到消息之后,做对应的同步es索引库,同步redis数据库(无论是增,删,改,都选择把redis的数据删除了.)的操作

  • 相关阅读:
    表单提交textarea内容,第一次获取不到值,第二次才能获取到的解决方法:
    连接oracle数据库报错:TNS-12516 TNS:listener could not find available handler with matching protocol stack解决方法
    【BZOJ 1272】 1272: [BeiJingWc2008]Gate Of Babylon (容斥原理+卢卡斯定理)
    【BZOJ 3456】 3456: 城市规划 (NTT+多项式求逆)
    【BZOJ 4332】 4332: JSOI2012 分零食 (FFT+快速幂)
    【BZOJ 4555】 4555: [Tjoi2016&Heoi2016]求和 (NTT)
    【BZOJ 4503】4503: 两个串 (FFT)
    【BZOJ 3771】 3771: Triple (FFT+容斥)
    【BZOJ 3160】 3160: 万径人踪灭 (FFT)
    【UOJ 34】 #34. 多项式乘法 (FFT)
  • 原文地址:https://www.cnblogs.com/tang0125/p/12685404.html
Copyright © 2011-2022 走看看