ajwlforever/community

community

牛客网论坛实战

一、环境的配置与项目启动

1. 使用的是Idea这个开发环境

2. start.spring.io打包开始项目

• 基本的包： aspects,web,thymleaf,devtools,logback,mybatis,mysql;

3. mysql安装 配置(my.ini)

   [mysql]
   default-character-set=utf8
   [mysqld]
   port=3306
   basedir=D:\AJWLFOREVER\就业\mysql-8.0.15-winx64
   max_connections=20
   character-set-server=utf8
   default-storage-engine=INNODB

4. properties

   # Server Properties
   server.port=8080
   server.servlet.context-path=/community
   
   # Thymeleaf Properties
   spring.thymeleaf.cache=false
   
   
   # DataSourceProperties
   spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
   spring.datasource.url=jdbc:mysql://localhost:3306/community?characterEncoding=utf-8&useSSL=false&serverTimezone=Hongkong&allowPublicKeyRetrieval=true
   spring.datasource.username=root
   spring.datasource.password=zjh5211314
   spring.datasource.type=com.zaxxer.hikari.HikariDataSource
   spring.datasource.hikari.maximum-pool-size=15
   spring.datasource.hikari.minimum-idle=5
   spring.datasource.hikari.idle-timeout=30000
   
   # MybatisProperties
   mybatis.mapper-locations=classpath:mapper/*.xml
   mybatis.type-aliases-package=com.ajwlforever.community.entity
   mybatis.configuration.useGeneratedKeys=true
   mybatis.configuration.mapUnderscoreToCamelCase=true
   
   # logger
   logging.level.com.nowcoder.community=debug
   logging.file=D:/AJWLFOREVER/nowcoder/logs/community.log
   

5. 开始编程！

二、版本控制工具git的使用

git 使用文档：https://git-scm.com/doc

1. 安装git

2. 配置git

   git config --list  //显示所有git配置
   git config  --global user.name "...."  //配置名字和邮箱
   git config  --global user.email "...."
   
   //项目管理cd到项目下
   git init  //创建git仓库
   git status 
   git add * //添加所有文件到仓库 暂存
   git commit -m "test1" //提交版本为test1
   
   //生成密钥
   ssh-keygen -t rsa -C "邮箱地址" //一直回车
   在提示下找到 id_rsa.pub文件，复制其中内容，在github上创建公钥，建立连接
   git remote add oringin ...网址...git 本地仓库与网络仓库连接 
   git push -u origin --all //上传到GitHub
   
   git clone ...网址...git //克隆项目
   git pull ... //从网络仓库拉项目
   
   
   
   

   3. Idea 设置上配置Git路径，直接在Idea上的Vcs使用Git 方便！

三、Spring简单介绍

1.spring guides

2.史上最全spring注解，没有之一

./spring.md

四、Spring MVC

MVC 设计不仅限于 Java Web 应用，还包括许多应用，比如前端、PHP、.NET 等语言。之所以那么做的根本原因在于解耦各个模块。

MVC 是 Model、View 和 Controller 的缩写，分别代表 Web 应用程序中的 3 种职责。

• 模型：用于存储数据以及处理用户请求的业务逻辑。
• 视图：向控制器提交数据，显示模型中的数据。
• 控制器：根据视图提出的请求判断将请求和数据交给哪个模型处理，将处理后的有关结果交给哪个视图更新显示。

五、网站架构图

六、邮件功能的实现

Redis 实现 点赞的功能

点赞包括 1.主页显示赞 2.post页面显示赞，点赞，取消赞 3.个人主页显示点赞。

1 redis在ssm中的使用

redis:https://redis.io/documentation

菜鸟教程：https://www.runoob.com/redis/redis-java.html

spring-redis官方文档：https://docs.spring.io/spring-data/data-redis/docs/2.5.x/reference/html/#preface

spring-redis官方api:https://docs.spring.io/spring-data/data-redis/docs/2.5.x/reference/html/#preface

spring-redis实例：spring-data-keyvalue-examples

spring-redis实例文档:https://docs.spring.io/spring-data/data-keyvalue/examples/retwisj/current/

1.依赖注入

<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis -->
<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2.属性设置

# Redis数据库索引（默认为0）
spring.redis.database=0  
# Redis服务器地址
spring.redis.host=127.0.0.1
# Redis服务器连接端口
spring.redis.port=6379  
# Redis服务器连接密码（默认为空）
spring.redis.password=
# 连接池最大连接数（使用负值表示没有限制）
spring.redis.pool.max-active=8  
# 连接池最大阻塞等待时间（使用负值表示没有限制）
spring.redis.pool.max-wait=-1  
# 连接池中的最大空闲连接
spring.redis.pool.max-idle=8  
# 连接池中的最小空闲连接
spring.redis.pool.min-idle=0  
# 连接超时时间（毫秒）
spring.redis.timeout=0  

2.redisTemplate 的配置

@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {

    /**
     * 选择redis作为默认缓存工具
     * @param redisTemplate
     * @return
     */
    @Bean
    public CacheManager cacheManager(RedisTemplate redisTemplate) {
        RedisCacheManager rcm = new RedisCacheManager(redisTemplate);
        return rcm;
    }

    /**
     * retemplate相关配置
     * @param factory
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {

        RedisTemplate<String, Object> template = new RedisTemplate<>();
        // 配置连接工厂
        template.setConnectionFactory(factory);

        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）
        Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);

        ObjectMapper om = new ObjectMapper();
        // 指定要序列化的域，field,get和set,以及修饰符范围，ANY是都有包括private和public
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型，类必须是非final修饰的，final修饰的类，比如String,Integer等会跑出异常
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jacksonSeial.setObjectMapper(om);

        // 值采用json序列化
        template.setValueSerializer(jacksonSeial);
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());

        // 设置hash key 和value序列化模式
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(jacksonSeial);
        template.afterPropertiesSet();

        return template;
    }

    /**
     * 对hash类型的数据操作
     *
     * @param redisTemplate
     * @return
     */
    @Bean
    public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForHash();
    }

    /**
     * 对redis字符串类型数据操作
     *
     * @param redisTemplate
     * @return
     */
    @Bean
    public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForValue();
    }

    /**
     * 对链表类型的数据操作
     *
     * @param redisTemplate
     * @return
     */
    @Bean
    public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForList();
    }

    /**
     * 对无序集合类型的数据操作
     *
     * @param redisTemplate
     * @return
     */
    @Bean
    public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForSet();
    }

    /**
     * 对有序集合类型的数据操作
     *
     * @param redisTemplate
     * @return
     */
    @Bean
    public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
        return redisTemplate.opsForZSet();
    }
}

4.本网站的config

@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory)
    {
        RedisTemplate<String,Object> template   = new RedisTemplate<>();
        template.setConnectionFactory(factory);


        template.setKeySerializer(RedisSerializer.string());
        template.setValueSerializer(RedisSerializer.json());
        template.setHashKeySerializer(RedisSerializer.string());
        template.setHashValueSerializer(RedisSerializer.json());
        template.afterPropertiesSet();

        return template;
    }
}

5.测试使用Redis

com.ajwlforever.community.RedisTest

2.实现点赞功能

1.redis中的数据格式

key(like:entity:entityType:entityId)	type	value（....用户集合）
like:entity:1:124 (对postid为124的帖子点赞)	string	{123,545,55,1,6}
like:entity:2:124 (commentid为124的评论点赞)	string	{123,545,55,1,6}

2.对数据进行操作

redisTemplate有详细说明，本网站用opsForSet 返回 SetOperations<K,V> 进行操作

官方api：https://docs.spring.io/spring-data/redis/docs/2.2.4.RELEASE/api/

3.重构点赞功能，主页显示赞

• 重构为用用户为key，记录点赞数量

  新增数据格式

  key(like:user:userId)	type	count(收到赞的数量)
  like:user:111	int	12
  like:user:112 (userId为112的用户)	int	12

  LikeService 服务中对redis数据操作多次，要开启事务

    redisTemplate.execute(new SessionCallback() {
              @Override
              public Object execute(RedisOperations operations) throws DataAccessException {
                  String entityLikeKey = RedisKeyUtil.getEntityLikeKey(entityType,entityId);
                  String userLikeKey = RedisKeyUtil.getUserLikeKey(entityUserId);
                  //查询是否已经赞过
                  boolean isMember = operations.opsForSet().isMember(entityLikeKey, userId);
                  operations.multi();
                  if(isMember)
                  {
                  	//取消赞，和减少赞的数量
                      operations.opsForSet().remove(entityLikeKey,userId);
                      operations.opsForValue().decrement(userLikeKey);
                  }else
                  {
                      operations.opsForSet().add(entityLikeKey,userId);
                      operations.opsForValue().increment(userLikeKey);
                  }
                  return operations.exec();
              }
          });
  

实现点赞中遇到的困难

1. thymleaf th:href 的使用问题：

 ```
 现在在 community/alpha/test_a这个页面上
 <a th:href="user"></a>  // http://localhost:8080/community/alpha/user
 <a th:href="|user|"></a>  // http://localhost:8080/community/alpha/user
 <a th:href="|user/${user.id}|"></a> //http://localhost:8080/community/alpha/user/1
 <a th:href="|/user/${user.id}|"></a> //http://localhost:8080/user/1
 <a th:href="@{user}"></a>  //http://localhost:8080/community/alpha/user
 <a th:href="@{'user'+${user.id}}"></a> //http://localhost:8080/community/alpha/user1
 <a th:href="@{'/user'+${user.id}}"></a>  //http://localhost:8080/community/user1
 ```
  
 @{}加上了ContextPath 
  
 |   | 不做处理
  
 / 是根地址

2.redis 事务

查询放在事务前，事务开启 operations.multi(),事务执行operations.exec();

4.redis扩展-关注取关，关注列表，粉丝列表

1.数据格式

//用户关注了哪个实体
followee:userId:entityType   -> zset(entityId,now) 按时间排序

followee key	type	value
followee:132:3	int	(111,currentSystemmills) ...
followee:152:3	int	(132,currentSystemmills)...

//某个实体粉丝
//follower:entityType:entityId  ->zset(userId,now)

follower key	type	value
follower:3:123	int	(111,currentSystemmills) ...
follower:3:133	int	(132,currentSystemmills)...

2.功能实现

com.ajwlforever.community.service.FollowService

redis 优化登录模块（验证码 , 存储登录凭证，用户信息）

1. 验证码

//验证码  kaptch:owner --> (text)
public static final String getKaptchKey(String owner)
{
	return PREFIX_KAPATCH+SPLIT+owner;
}

2.存储登录凭证

//不再将LoginTicket 存放到mysql，而是放到 redis

//Ticket ticket:(ticket) --> set(class LoginTicket)
public static final String getTicketKey(String ticket)
{
    return PREFIX_TICKET+SPLIT+ticket;
}

3.缓存用户信息 redis存放用户缓存

页面中的用户优先从缓存取

// 1.优先从缓存中取值
private User getCache(int userId) {
    String redisKey = RedisKeyUtil.getUserKey(userId);
    return (User) redisTemplate.opsForValue().get(redisKey);
}

// 2.取不到时初始化缓存数据
private User initCache(int userId) {
    User user = userMapper.selectById(userId);
    String redisKey = RedisKeyUtil.getUserKey(userId);
    redisTemplate.opsForValue().set(redisKey, user, 3600, TimeUnit.SECONDS);
    return user;
}

// 3.数据变更时清除缓存数据
private void clearCache(int userId) {
    String redisKey = RedisKeyUtil.getUserKey(userId);
    redisTemplate.delete(redisKey);
}

Kafka,构建TB级异步消息系统

1.阻塞队列 （不采用Kafka） Kafka底层 Java自带Api

• BlockingQueue 接口(在两个线程间搭建了一个桥梁，避免直接交流)
  • 解决线程通信问题
  • 阻塞方法：put、take
• 生产者消费者模式
  • 生产者：生产数据的线程
  • 消费者 ：使用数据的线程
• 实现类：
  • ArrayBlockingQueue
  • LInkedBlockingQueue
  • PriorityBlockingQueue、SynchronousQueue、DelayQueue

2.kafka

• 简介
  • 分布式流媒体平台
  • 应用：消息系统、日志收集、用户行为追踪、流式处理
• 特点：高吞吐量、消息持久化(硬盘顺序读)、高可靠性（分布式，可搭建集群）、高扩展性
• Kafka术语
  • Broker（kafka服务器）、Zookeeper（用来管理集群）
  • Topic、Partition、Offset
  • Leader Replica、Followe Replica

官网 kafka.apache.org

安装: (安装的目录层级不应太深)

1. ​ 官网下载，开启。配置zookeeper.properties,server.properties;

2. ​ 开启zookeeper， zookeeper-server-start.bat config\zookeeper.properties

3. ​ 开启使用kafka

   • kafka-topics.bat --create --bootstrap-server localhost:9092(默认服务器) --replication-factor（副本） 1 --partitions 1 --topic test

   kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

   
   
   
   -  kafka-topics.bat --list  --bootstrap-server 显示所有主题
   
   -  kafka-console-producer.bat  --broker-list localhost:9092 --topic test
   
   hello world  （发送消息）
   
   -	另启窗口，接受消息   kafka-console-consumercd.bat  --bootstrap-server localhost:9092 --topic test --from-beginning
   
   

3.Spring整合kafka

• 引入依赖

  • spring-kafka

    <!-- https://mvnrepository.com/artifact/org.springframework.kafka/spring-kafka -->
    <dependency>
        <groupId>org.springframework.kafka</groupId>
        <artifactId>spring-kafka</artifactId>
        <version>2.6.6</version>
    </dependency>
    
    

• 配置kafka

  • 配置server、consumer

    spring.kafka.bootstrap-servers=localhost:9092
    spring.kafka.consumer.group-id=community-consumer-group
    spring.kafka.consumer.enable-auto-commit=true  //自动提交偏移
    spring.kafka.consumer.auto-commit-interval=3000 //提交间隔
    

• 访问kafka

  • 生产者

    kafkaTemplate.send(topic, data);

  • 消费者

    @KafkaListener(topics = {“test”})

    public void handleMessage（ConsumerRecord record）{}

2.通知功能

发送系统通知

• 处理事件，都封装成事件，异步并发

  

  1. 这三者发出消息的动作形式极度相似，都是一个用户对某一个实体的操作，所以可以封装一个事件类，同时处理这三种操作。

显示系统通知

• 对数据库读取，显示到视图层

点赞，评论，关注功能的架构图