（eblog）9、博客搜索引擎开发、后台精选

注意这个按钮其实是一个form表单的提交按钮&＃xff0c;这样我们就不再需要写js了&＃xff0c;因为已经有全局的form表单的js。

改动同步

接下来我们做些数据改动同步的问题&＃xff0c;当我们添加修改或者删除了文章数据时候&＃xff0c;es能同步修改。

这里我们使用的是mq&＃xff0c;数据发送变化时候&＃xff0c;发送一条消息到MQ&＃xff0c;然后mq消费端接受消息然后把这条消息的最新状态同步到ES中

首先类配置一下mq。新建一个RabbitMqConfig类放在config包下。我们先来回顾一下消息队列的内容&＃xff0c;RabbitMQ里面发送接收消息有几种类型

• Direct类型&＃xff08;路由模式&＃xff09;

• Fanout 类型&＃xff08;发布订阅模式&＃xff09;

• Topic类型&＃xff08;通配符模式&＃xff09;

这里我们直接使用Direct模式即可。这里会涉及到队列Queue、交换机Exchange、还有路由键RouteKey&＃xff08;BindingKey&＃xff09;。

发布者发送消息到交换机&＃xff0c;通过交换机和队列的路由键&＃xff0c;把消息推向队列并保存起来&＃xff0c;然后消费者订阅队列处理消息即可。

所以在RabbitMqConfig里面我们需要声明一下queue、exchange、routekey。并且绑定起来。

• com.example.config.RabbitMqConfig

&＃64;Configuration
public class RabbitMqConfig {// 队列名称public final static String ES_QUEUE &＃61; "es_queue";public final static String ES_EXCHANGE &＃61; "es_exchange";public final static String ES_BIND_KEY &＃61; "es_index_message";/*** 声明队列* &＃64;return*/&＃64;Beanpublic Queue exQueue() {return new Queue(ES_QUEUE);}/*** 声明交换机* &＃64;return*/&＃64;BeanDirectExchange exchange() {return new DirectExchange(ES_EXCHANGE);}/*** 绑定交换机和队列* &＃64;param exQueue* &＃64;param exchange* &＃64;return*/&＃64;BeanBinding bindingExchangeMessage(Queue exQueue, DirectExchange exchange) {return BindingBuilder.bind(exQueue).to(exchange).with(ES_BIND_KEY);}
}


关于消费者和生产者之间的消息&＃xff0c;我们需要一个共同约定类型。这里我需要新建一个消息模板&＃xff0c;生产者发布消息时候只需要往消息模板填写&＃xff0c;然后发送过来&＃xff0c;消费者就能根据消息模板来处理消息。消息模板的内容需要斟酌一下&＃xff0c;首先需要一个类型&＃xff0c;因为是es与数据库数据的同步&＃xff08;比如新发表、更新、删除了一篇文章&＃xff09;。不同类型需要不同的处理手段。然后文章的id需要的。然后如果es处理数据失败的话我们需要重试&＃xff0c;重试次数是有限的&＃xff0c;所以这里我们定义一个重试次数的字段。

代码如下&＃xff1a;

• com.example.search.common.PostMqIndexMessage

/*** 用于服务之间消息通讯模板*/
&＃64;Data
public class PostMqIndexMessage {public static final String CREATE &＃61; "create";public static final String UPDATE &＃61; "update";public static final String REMOVE &＃61; "remove";public static final int MAX_RETRY &＃61; 3;private Long postId;private String type;private int retry &＃61; 0;public PostMqIndexMessage() {}public PostMqIndexMessage(Long postId, String type) {this.postId &＃61; postId;this.type &＃61; type;}public PostMqIndexMessage(Long postId, String type, int retry) {this.postId &＃61; postId;this.type &＃61; type;this.retry &＃61; retry;}
}


因为消息发送都是通过经过序列化的json数据&＃xff0c;所以我们先用String类型把消息内容接受&＃xff0c;然后让内容与消息模板进行转换。可以使用ObjectMapper这个工具。然后接下来就是根据消息类型来处理消息了。

• com.example.mq.HandlerMessage

/*** 监听异步消息队列* 更新搜索内容*/
&＃64;Slf4j
&＃64;Component
&＃64;RabbitListener(queues &＃61; RabbitMqConfig.ES_QUEUE)
public class HandlerMessage {&＃64;Autowiredprivate ObjectMapper objectMapper;&＃64;AutowiredSearchService searchService;&＃64;RabbitHandlerpublic void handler(String content) {try {PostMqIndexMessage message &＃61; objectMapper.readValue(content, PostMqIndexMessage.class);switch (message.getType()) {case PostMqIndexMessage.CREATE:case PostMqIndexMessage.UPDATE:searchService.createOrUpdateIndex(message);break;case PostMqIndexMessage.REMOVE:searchService.removeIndex(message);break;default:log.warn("没有找到对应的消息类型&＃xff0c;请注意&＃xff01;&＃xff01;&＃xff01;, ---> {}", content);break;}} catch (IOException e) {log.error("这是内容----> {}", content);log.error("处理HandlerMessage失败 --> ", e);}}
}


接下来我们就去SearchService里去写对应的方法。首先看createOrUpdateIndex方法&＃xff0c;在ElasticsearchRepository里面&＃xff0c;更新或者新建都是用save方法&＃xff0c;所以步骤基本都一直&＃xff0c;新建类型里我先删掉原来的&＃xff08;如果有&＃xff09;。其他没啥不一样了。

然后我们注重看下createOrUpdateIndex和removeIndex两个方法&＃xff0c;创建或修改其实很简单&＃xff0c;只需要把修改的数据查询出来&＃xff0c;然后转换成PostDocument就可以直接持久化了&＃xff0c;

• com.example.service.impl.SearchServiceImpl

/*** 异步创建或者更新*/
public void createOrUpdateIndex(PostMqIndexMessage message) {long postId &＃61; message.getPostId();PostVo postVo &＃61; postService.selectOne(new QueryWrapper().eq("p.id", postId));log.info("需要更新的post --------> {}", postVo.toString());if(PostMqIndexMessage.CREATE.equals(message.getType())) {if(postRepository.existsById(postId)) {this.removeIndex(message);}}PostDocument postDocument &＃61; new PostDocument();modelMapper.map(postVo, postDocument);PostDocument saveDoc &＃61; postRepository.save(postDocument);log.info("es 索引更新成功&＃xff01;--> {}" , saveDoc.toString());
}


删除也差不多&＃xff0c;直接通过id就可以删除

&＃64;Override
public void removeIndex(PostMqIndexMessage message) {long postId &＃61; message.getPostId();postRepository.deleteById(postId);log.info("es 索引删除成功&＃xff01;--> {}" , message.toString());


}

有了mq的消费端&＃xff0c;那么在哪里发送mq消息呢&＃xff1f;在增删改数据的时候发送一条mq消息。我们找到对应的方法&＃xff1a;

• com.example.controller.PostController#submit

其中mq的发送模板是AmqpTemplate &＃xff0c;直接注入即可。

&＃64;Autowired
AmqpTemplate amqpTemplate;


删除也类似&＃xff1a;

• com.example.controller.PostController#delete

发送了mq之后&＃xff0c;消费端就会同步es的数据&＃xff0c;所以我们能保证es的数据和数据库的数据实时保持一致。

致此&＃xff0c;搜索功能已经完成。

后台管理

置顶精选

关于文章的指定精选删除等功能&＃xff0c;都是后台管理员能操作的动作&＃xff0c;指定和精选其实都是post的一个状态问题&＃xff0c;所以逻辑上特别简单&＃xff0c;而且原js已经帮我们写好了方法&＃xff0c;所以我们只需修改一下链接&＃xff0c;然后在AdminController中添加对应的处理逻辑即可。

先来看下前端&＃xff1a;

• static/res/mods/jie.js

//设置置顶、状态
,set: function(div){var othis &＃61; $(this);fly.json(&＃39;/admin/jie-set/&＃39;, {id: div.data(&＃39;id&＃39;),rank: othis.attr(&＃39;rank&＃39;),field: othis.attr(&＃39;field&＃39;)}, function(res){if(res.status &＃61;&＃61;&＃61; 0){location.reload();}});
}


可以看到&＃xff0c;发起链接时候有几个参数&＃xff0c;id&＃xff0c;rank&＃xff0c;field等。然后看看html&＃xff1a;

• templates/post/view.ftl

<&＃64;shiro.hasRole name&＃61;"admin">删除<#if post.level &＃61;&＃61; 0>置顶<#if post.level gt 0>取消置顶<#if !post.recommend>加精<#if post.recommend>取消加精



因为是后台管理操作&＃xff0c;所以需要<&＃64;shiro.hasRole name&＃61;"admin">这个admin权限&＃xff0c;然后我们需要在Shiro的Realm中声明一下权限的问题&＃xff0c;这里我比较简单&＃xff0c;没有写权限模块&＃xff0c;直接写死了admin作为超级管理员&＃xff1a;

• com.example.shiro.AccountRealm

&＃64;Override
protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principalCollection) {AccountProfile principal &＃61; (AccountProfile) principalCollection.getPrimaryPrincipal();// 硬编码if(principal.getUsername().equals("admin") || principal.getId() &＃61;&＃61; 1){SimpleAuthorizationInfo info &＃61; new SimpleAuthorizationInfo();info.addRole("admin");return info;}return null;
}


可以看到硬编码写死了用户admin或者id为1有角色admin&＃xff0c;其他都没有任何权限和角色。然后我们再看看AdminController

• com.example.controller.AdminController

&＃64;ResponseBody
&＃64;PostMapping("/jie-set")
public Result jieSet(Long id, Integer rank, String field) {Post post &＃61; postService.getById(id);Assert.isTrue(post !&＃61; null, "该文章已被删除");if("delete".equals(field)) {postService.removeById(id);return Result.succ(null);} else if("stick".equals(field)) {post.setLevel(rank);} else if("status".equals(field)) {post.setRecommend(rank &＃61;&＃61; 1);}postService.updateById(post);return Result.succ(null);
}


直接就调用updateById修改状态即可。这里还有一个删除功能&＃xff0c;也就是说不仅仅本人可以删除&＃xff0c;超级管理员也有权限删除文章了。

 给eblog一个star&＃xff0c;感谢支持哈