发布于2021-05-29 21:10 阅读(1373) 评论(0) 点赞(18) 收藏(3)
微信朋友圈数据缓存在手机内存,视频大量弹幕即海量数据先缓存再写入关系型数据库。如下存储文件第一次用是没有的。如下蓝横线是快捷方式并最后加上.conf文件。Mysql默认3306端口,tomcat默认8080端口。redis-cli.exe命令行客户端不好用,用图形化客户端。
Nosql产品如下,Redis劣势是value类型有5种,没有固定结构。HBase分布式像二叉树查询效率高,数据不断添加,所以扩展性强。MongoDB像杂物袋,分门别类没必要。
因为元素不重复,所以可无序。重索序。
如下理解score是分数可重复。
如下RDB中900秒即15分钟,如0-15分钟操作2次,拍1次照保存硬盘。但15-27分钟又操作2次(只符合save 900 1策略),这时redis崩溃了,15-30分钟才拍照保存,所以丢失了2条数据。所以不频繁操作会丢数据。
如下AOF中写日志不是把整张照记录起来,而是记录一步(保存快),读取慢因为要从头看到尾
,才能把整个过程联系起来。AOF只能三者选其一,不像RDB三个策略都在线(默认开启),AOF是RDB(会丢数据)的补丁
。在redis_windows.conf修改appendonly为yes,所以之前将redis_windows.conf文件名添加到快捷方式的目标中。
场景:每10秒2000次(一共8*2000=16000次),每分钟60秒12000次(此时RDB拍一次照,剩下20秒来不及拍,因为太频繁拍照会卡)。为什么先用RDB?因为读取快。
package com.itheima01.jedis;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class JedisDemo {
@Test
public void method01(){
String host = "127.0.0.1";
int port = 6379;
Jedis jedis = new Jedis(host, port); //1. 创建连接,不用连接池
jedis.set("book","thinking"); //2. 访问redis
jedis.hset("student","name","zs");
jedis.close(); //3. 关闭连接
System.out.println("测试");
}
@Test
public void method02(){
String host = "127.0.0.1";
int port = 6379;
JedisPoolConfig config = new JedisPoolConfig(); //连接池
config.setMaxTotal(5); //最大连接数
config.setMaxWaitMillis(2000); // 最长等待时间
config.setMaxIdle(2); // 最大空闲数:最多允许两个连接不干活,超过两个会被回收掉,达到释放内存目的
JedisPool pool = new JedisPool(config, host, port); //1. 初始化连接池
Jedis jedis = pool.getResource(); //2. 获取连接
String book = jedis.get("book"); //3. 访问redis
System.out.println(book); //thinking
jedis.close(); //4. 将连接还给连接池
pool.close(); // 销毁连接池,一般只有应用关闭时才用
}
@Test
public void method03(){ //测试封装的框架
Jedis jedis = JedisUtil.getResource();
String book = jedis.get("book");
System.out.println(book + "-------");
jedis.close();
}
}
package com.itheima01.jedis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
import java.util.ResourceBundle;
public class JedisUtil {
private static JedisPool pool;
/* static{
String host = "127.0.0.1";
int port = 6379;
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(5); //最大连接数
config.setMaxWaitMillis(2000); // 最长等待时间
config.setMaxIdle(2); // 最大空闲数
pool = new JedisPool(config, host, port);
}*/
//如下可替代如上
/*static{
Properties p = new Properties();
InputStream is = JedisUtil.class.getClassLoader().getResourceAsStream("jedis.properties");
try {
p.load(is);
String host = p.getProperty("host");
Integer port = Integer.parseInt(p.getProperty("port"));
Integer maxTotal = Integer.parseInt(p.getProperty("maxTotal"));
Integer maxWaitMillis = Integer.parseInt(p.getProperty("maxWaitMillis"));
Integer maxIdle = Integer.parseInt(p.getProperty("maxIdle"));
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(maxTotal); //最大连接数
config.setMaxWaitMillis(maxWaitMillis); // 最长等待时间
config.setMaxIdle(maxIdle); // 最大空闲数
pool = new JedisPool(config, host, port);
} catch (IOException e) {
e.printStackTrace();
}
}*/
//如下可替代如上
static{
/*
* ResourceBundle : 资源堆
* 1. 底层: 类加载器 -> 文件必须放在src下
* 2. 只能加载properties文件 -> 文件的后缀名.properties不要写。
* 用来替代Properties成为 properties文件专属解析类
* */
ResourceBundle bundle = ResourceBundle.getBundle("jedis");
String host = bundle.getString("host");
Integer port = Integer.parseInt(bundle.getString("port"));
Integer maxTotal = Integer.parseInt(bundle.getString("maxTotal"));
Integer maxWaitMillis = Integer.parseInt(bundle.getString("maxWaitMillis"));
Integer maxIdle = Integer.parseInt(bundle.getString("maxIdle"));
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(maxTotal); //最大连接数
config.setMaxWaitMillis(maxWaitMillis); // 最长等待时间
config.setMaxIdle(maxIdle); // 最大空闲数
pool = new JedisPool(config, host, port);
}
public static Jedis getResource(){
Jedis jedis = pool.getResource();
return jedis;
}
}
//jedis.properties文件
host = 127.0.0.1
port = 6379
maxTotal = 5
maxWaitMillis = 2000
maxIdle = 2
//index.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
<script src="js/jquery-3.3.1.min.js"></script>
<script>
$(function () { //页面加载事件
$.get("/FriendServlet","",function (data) {
// console.log(data)
var content = ""
$(data).each(function (index,element) {
content += "<li>" + element.name + "</li>"
})
$("#myid").html(content) //因为<li>是html
},"json")
})
</script>
</head>
<!--1111111111111111111111111111111111111111111111111111111111111111-->
<body>
<ul id="myid">
</ul>
</body>
</html>
package com.heima.example.web;
import com.heima.example.service.FriendService;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
@WebServlet(urlPatterns = "/FriendServlet")
public class FriendServlet extends HttpServlet {
@Override
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doGet(request, response);
}
@Override
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
FriendService service = new FriendService(); //调用service层代码
String json = service.findAllFriend();
response.setContentType("text/html;charset=utf-8");
response.getWriter().print(json);
}
}
package com.heima.example.service;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.heima.example.bean.Friend;
import com.heima.example.dao.FriendDao;
import com.itheima01.jedis.JedisUtil;
import com.sun.org.apache.bcel.internal.generic.NEW;
import redis.clients.jedis.Jedis;
import java.util.List;
/*
* service层: 业务逻辑 + 缓存 cache
* 弊端: 数据不更新 (查询走缓存, 如果执行增删查, 重新查询数据库,更新缓存)
* 如上括号里的解决方案也会存在缓存延迟的情况(如朋友圈删除动态有时也能看见)
* 朋友圈不是实时同步,如果实时同步对服务器来说压力大,好友列表的在线状态是实时同步的,用心跳长连接
*/
public class FriendService { //service文件夹下
public static final String FRIEND_LIST_CACHE = "example_friend_list";
//选中再ctrl + shift + u转为大写,"example_friend_list"变量改了,下面FRIEND_LIST_CACHE常量不用改
public String findAllFriend() throws JsonProcessingException {
Jedis jedis = JedisUtil.getResource();
String json = jedis.get(FRIEND_LIST_CACHE); //直接从缓存里取
if(json == null){ //就从mysql数据库中取
FriendDao dao = new FriendDao();
List<Friend> list = dao.findAll();
ObjectMapper om = new ObjectMapper();
json = om.writeValueAsString(list); //list转换为json
jedis.set(FRIEND_LIST_CACHE,json); //记得往缓存里放一份json即字符串
System.out.println("从mysql中查");
}else{
System.out.println("从redis中查");
}
jedis.close(); //记得还给连接池,不然5个用完就崩了
return json;
}
}
package com.heima.example.dao;
import com.heima.example.bean.Friend;
import com.heima.example.utils.JdbcUtil;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import java.util.List;
public class FriendDao { //Dao文件夹下
public List<Friend> findAll() {
String sql = "select * from user";
JdbcTemplate template = JdbcUtil.getTemplate();
List<Friend> list = template.query(sql, new BeanPropertyRowMapper<>(Friend.class));
return list;
}
}
package com.heima.example.bean;
public class Friend { //bean文件夹下
private Integer id;
private String name;
private String password;
@Override
public String toString() {
return "Friend{" +
"id=" + id +
", name='" + name + '\'' +
", password='" + password + '\'' +
'}';
}
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
作者:我很伤感
链接:http://www.javaheidong.com/blog/article/207388/3c09d62a070c4f1e58f8/
来源:java黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容:(最多支持255个字符)
---无人问津也好,技不如人也罢,你都要试着安静下来,去做自己该做的事,而不是让内心的烦躁、焦虑,坏掉你本来就不多的热情和定力
Copyright © 2018-2021 java黑洞网 All Rights Reserved 版权所有,并保留所有权利。京ICP备18063182号-2
投诉与举报,广告合作请联系vgs_info@163.com或QQ3083709327
免责声明:网站文章均由用户上传,仅供读者学习交流使用,禁止用做商业用途。若文章涉及色情,反动,侵权等违法信息,请向我们举报,一经核实我们会立即删除!