文章列表：
1、初识Spring Boot，开发社区首页
2、开发社区登录模块
3、开发社区核心功能
开发社区核心功能
1 过滤敏感词
前缀树：根节点为空，除了根节点外的节点只包含一个字母
检测敏感词需要三个指针：第一个指针指向树，第二、三个指针指向字符串，遍历时分别指向敏感词的开头与结尾
检测到的结果存到StringBuilder里
1.1 定义前缀树
//前缀树private class TrieNode{//关键词结束的标识private boolean isKeywordEnd = false;//子节点（key是子节点字符，value是子节点）private Map<Character, TrieNode> subNodes = new HashMap<>();public boolean isKeywordEnd() {return isKeywordEnd;}public void setKeywordEnd(boolean keywordEnd) {isKeywordEnd = keywordEnd;}//添加子节点public void addSubNode(Character c,TrieNode node){subNodes.put(c, node);}//获取子节点public TrieNode getSubNode(Character c){return subNodes.get(c);}}
1.2 根据敏感词，初始化前缀树
//根节点private TrieNode rootNode = new TrieNode();//初始化@PostConstruct//当容器实例化这个Bean之后，在调用构造方法之后这个方法被自动调用public void init(){try(InputStream is = this.getClass().getClassLoader().getResourceAsStream("sensitive-words.txt");BufferedReader reader = new BufferedReader(new InputStreamReader(is));){String keyword;while((keyword=reader.readLine()) != null){//添加到前缀树this.addKeyword(keyword);}}catch (IOException e){logger.error("加载敏感词文件失败"+e.getMessage());}}//将一个敏感词添加到前缀树中去private void addKeyword(String keyword){TrieNode tempNode = rootNode;for(int i=0;i<keyword.length();i++){char c = keyword.charAt(i);TrieNode subNode = tempNode.getSubNode(c);if(subNode==null){//初始化子节点subNode = new TrieNode();tempNode.addSubNode(c,subNode);}//指向子节点，进入下一轮循环tempNode=subNode;//设置结束的标识if(i==keyword.length()-1){tempNode.setKeywordEnd(true);}}}
1.3 编写过滤敏感词的方法
//替换符private static final String REPLACEMENT = "***";/*** 过滤敏感词* @param text 待过滤的文本* @return 过滤后的文本*/public String filter(String text){if(StringUtils.isBlank(text)){return null;}//指针1：指向树的节点TrieNode tempNode = rootNode;//指针2：遍历字符串指针，指向敏感词首位int begin = 0;//指针3：指向敏感词末尾int position=0;//结果StringBuilder sb = new StringBuilder();while (position < text.length()) {char c = text.charAt(position);// 跳过符号if (isSymbol(c)) {// 若指针1处于根节点,将此符号计入结果,让指针2向下走一步if (tempNode == rootNode) {sb.append(c);begin++;}// 无论符号在开头或中间,指针3都向下走一步position++;continue;}// 检查下级节点tempNode = tempNode.getSubNode(c);if (tempNode == null) {// 以begin开头的字符串不是敏感词sb.append(text.charAt(begin));// 进入下一个位置position = ++begin;// 重新指向根节点tempNode = rootNode;} else if (tempNode.isKeywordEnd()) {// 发现敏感词,将begin~position字符串替换掉sb.append(REPLACEMENT);// 进入下一个位置begin = ++position;// 重新指向根节点tempNode = rootNode;} else {// 检查下一个字符position++;}}// 将最后一批字符计入结果sb.append(text.substring(begin));return sb.toString();}//判断是否为符号private boolean isSymbol(Character c){return !CharUtils.isAsciiAlphanumeric(c) && (c<0x2E80 || c>0x9FFF);//东亚文字范围}
1.4 测试
@RunWith(SpringRunner.class)@SpringBootTest@ContextConfiguration(classes = CommunityApplication.class)public class SensitiveTests {@Autowiredprivate SensitiveFilter sensitiveFilter;@Testpublic void testSeneitiveFilter(){String text="这里可以赌博，可以嫖娼，可以吸毒，可以开票";text = sensitiveFilter.filter(text);System.out.println(text);text="这里可以%赌%博%，可以%嫖%娼%，可以%吸%毒%，可以%开%票%";text = sensitiveFilter.filter(text);System.out.println(text);}}
2 发布帖子
发布帖子需要用到异步请求：当前网页不刷新，访问服务器，服务器会返回一些结果，这个结果不是网页，通过结果对当前网页做局部刷新
2.1 AJAX
AJAX：异步的js和xml
2.2 示例：使用jQuery发送AJAX请求
public static String getJSONString(int code, String msg, Map<String,Object> map){JSONObject json = new JSONObject();json.put("code",code);json.put("msg", msg);if(map!=null){for(String key : map.keySet()){json.put(key, map.get(key));}}return json.toJSONString();}public static String getJSONString(int code, String msg){return getJSONString(code, msg, null);}public static String getJSONString(int code){return getJSONString(code, null, null);}//main方法用于测试JSON方法public static void main(String[] args){Map<String, Object> map = new HashMap<>();map.put("name", "zhangsan");map.put("age", 25);System.out.println(getJSONString(0, "ok", map));}
@Controller@RequestMapping("/alpha")public class AlphaController {//AJAX示例@RequestMapping(path = "/ajax",method = RequestMethod.POST)@ResponseBody//异步请求，不返回网页，只返回字符串public String testAjax(String name,int age){System.out.println(name);System.out.println(age);return CommunityUtil.getJSONString(0,"操作成功");}}
<!DOCTYPE html><html lang="en"><head><meta charset="UTF-8"><title>AJAX</title></head><body><p><input type="button" value="发送" onclick="send();"></p><script src="/jquery-3.3.1.min.js" crossorigin="anonymous"></script><script>function send() {$.post("/community/alpha/ajax",{"name":"张三","age":23},function(data) {console.log(typeof(data));console.log(data);data = $.parseJSON(data);console.log(typeof(data));console.log(data.code);console.log(data.msg);});}</script></body></html>
2.3 实践：采用AJAX请求，实现发布帖子的功能
1.数据访问层：增加一个插入帖子的方法
2.业务层：增加一个发帖方法（调用数据访问层），转义HTML字符，敏感词过滤
3.视图层：异步方式，需要写js代码
注意返回的是字符串，要加上@ResponseBody
方法的参数：页面上传入的内容
4.修改前端网页为动态引擎
3 帖子详情
开发过程：很详细了！
Controller层知识点：
1.@PathVariable：在路径中获取参数
@RequestMapping(path="/detail/{discussPostId}",method = RequestMethod.GET)public String getDiscussPost(@PathVariable("discussPostId") int discussPostId, Model model){...}
2.通过model将参数发送给模板引擎
model.addAttribute("post", post);
<span th:utext="${post.title}">
3.返回模板路径
return "site/discuss-detail";
4 事务管理
4.1 声明式事务
@Servicepublic class AlphaService {@Autowiredprivate UserMapper userMapper;@Autowiredprivate DiscussPostMapper discussPostMapper;//propagation传播机制 a调用b//REQUIRED 支持当前事务，如果不存在，就创建新事物//REQUIRES_NEW 创建新事物且暂停当前事务//NESTED 如果当前存在事务，则嵌套在该事务中执行；否则和REQUIRED一样@Transactional(isolation = Isolation.READ_COMMITTED,propagation = Propagation.REQUIRED)public Object save1(){//新增用户User user = new User();user.setUsername("alpha");user.setSalt(CommunityUtil.generateUUID().substring(0,5));user.setPassword(CommunityUtil.md5("123"+user.getSalt()));user.setEmail("alpha@");user.setHeaderUrl("/head/99t.png");user.setCreateTime(new Date());userMapper.insertUser(user);//新增帖子DiscussPost post = new DiscussPost();post.setUserId(user.getId());post.setTitle("hello");post.setContent("hi");post.setCreateTime(new Date());discussPostMapper.insertDiscussPost(post);Integer.valueOf("abc");return "ok";}}
@RunWith(SpringRunner.class)@SpringBootTest@ContextConfiguration(classes = CommunityApplication.class)public class TransactionTests {@Autowiredprivate AlphaService alphaService;@Testpublic void testSave1(){Object obj = alphaService.save1();System.out.println(obj);}}
4.2 编程式事务
@Autowiredprivate TransactionTemplate transactionTemplate;public Object save2(){//设置隔离级别transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);//设置传播机制transactionTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);//执行SQL访问事务return transactionTemplate.execute(new TransactionCallback<Object>() {@Overridepublic Object doInTransaction(TransactionStatus transactionStatus) {//新增用户User user = new User();user.setUsername("beta");user.setSalt(CommunityUtil.generateUUID().substring(0,5));user.setPassword(CommunityUtil.md5("123"+user.getSalt()));user.setEmail("beta@");user.setHeaderUrl("/head/999.png");user.setCreateTime(new Date());userMapper.insertUser(user);//新增帖子DiscussPost post = new DiscussPost();post.setUserId(user.getId());post.setTitle("nihao");post.setContent("11");post.setCreateTime(new Date());discussPostMapper.insertDiscussPost(post);Integer.valueOf("abc");return "ok";}});}
@Testpublic void testSave2(){Object obj = alphaService.save2();System.out.println(obj);}
5 显示评论
5.1 数据层
0.先对数据库有个了解：
entity_type：评论的对象可以是帖子、帖子里的评论、课程、题，等等
target_id：记录评论指向的人（不太懂）
status：0表示正常，1表示被删除
1.新建实体类，属性与表一致、get/set方法、toString
2.新建Mapper接口，注解@Mapper，声明查询方法
3.写mapper对应的xml，实现查询方法
知识点：
（1）namespace=对应的mapper地址
（2）id对应mapper里的方法名，resultType对应返回类型
5.2 业务层
1.注解@Service
2.注入Mapper
5.3 表现层
page分页有点问题，不能直接点数字，只能点其他按钮
6 添加评论
要用到事务了
这里的分页也有点问题：评论后在最后页，刷新后重定向在第一页。在最后页回复评论，刷新后重定向又在第一页
错误：不知道哪里代码错了，评论后”评论数“并没有增加，把老师代码全部粘过来，刷新也不会增加，去数据库改了之后，再评论就会增加”评论数“。所以有关数据库的错误，保证代码没错之后要在数据库把相应的数据改过来。
7 私信列表
conversation_id：会话id，小id_大id
status：0-未读;1-已读;2-删除
表现层实现两个功能：私信列表、点进去之后的私信详情
私信列表：用户名、头像、私信条数、时间等（这些信息用Map包装），循环
分页可以复用首页的逻辑
aaa用户的密码是aaa
8 发送列表
9 统一异常处理
无论是哪个层次的异常，都会汇到表现层，要对表现层统一处理异常
Spring Boot自动给我们的处理：将error文件夹拖拽到templates目录下（文件夹名一定要叫error，error下的文件名一定要是错误状态：404，500等）
@ControllerAdvice(annotations = Controller.class)//该注解只扫描带有controller注解的Beanpublic class ExceptionAdvice {private static final Logger logger = LoggerFactory.getLogger(ExceptionAdvice.class);@ExceptionHandler({Exception.class})//所有异常都用该方法处理public void handleException(Exception e, HttpServletRequest request, HttpServletResponse response) throws IOException {logger.error("服务器发生异常：" + e.getMessage());for(StackTraceElement element : e.getStackTrace()){logger.error(element.toString());}String xRequestedWith = request.getHeader("x-requested-with");//请求方式if("XMLHttpRequest".equals(xRequestedWith)){//异步请求response.setContentType("application/plain;charset=utf-8");PrintWriter writer = response.getWriter();writer.write(CommunityUtil.getJSONString(1,"服务器异常"));}else{//普通请求response.sendRedirect(request.getContextPath()+"/error");}}}
10 统一记录日志
将日志写在Service里的话，万一要更改就很麻烦，如果将记录日志单独实现就会方便很多，AOP可以做到这一点
步骤：
1.加注解@Component
2.加注解@Aspect
3.声明切点
@Pointcut("execution(* munity.service.*.*(..))")public void pointcut(){}
4.写具体要执行的操作
//在连接点之前做一些事情@Before("pointcut()")public void before(){System.out.println("before");}
示例：
@Component//声明为Bean@Aspect//声明为Aspect组件public class AlphaAspect {@Pointcut("execution(* munity.service.*.*(..))")//切点,第一个*表示方法的返回值，后面两个*表示包名下的所有类的所有方法，(..)表示方法里所有的参数public void pointcut(){}//在连接点之前做一些事情@Before("pointcut()")public void before(){System.out.println("before");}//在连接点后面做一些事情@After("pointcut()")public void after(){System.out.println("after");}//在返回值以后做一些事情@AfterReturning("pointcut()")public void afterReturning(){System.out.println("afterReturning");}//在抛出异常以后做一些事情@AfterThrowing("pointcut()")public void afterThrowing(){System.out.println("afterThrowing");}//在前后@Around("pointcut()")public Object around(ProceedingJoinPoint joinPoint) throws Throwable{System.out.println("around-before");Object obj = joinPoint.proceed();System.out.println("around-after");return obj;}}
清空控制台：
