当前位置:   article > 正文

【Elasticsearch】学习笔记-p8

【Elasticsearch】学习笔记-p8

hotel-adminhotel-demo中引入rabbitmq的依赖:

org.springframework.boot

spring-boot-starter-amqp

(2)声明队列交换机名称

hotel-adminhotel-demo中的cn.itcast.hotel.constatnts包下新建一个类MqConstants

package cn.itcast.hotel.constatnts;

public class MqConstants {

/**

  • 交换机

*/

public final static String HOTEL_EXCHANGE = “hotel.topic”;

/**

  • 监听新增和修改的队列

*/

public final static String HOTEL_INSERT_QUEUE = “hotel.insert.queue”;

/**

  • 监听删除的队列

*/

public final static String HOTEL_DELETE_QUEUE = “hotel.delete.queue”;

/**

  • 新增或修改的RoutingKey

*/

public final static String HOTEL_INSERT_KEY = “hotel.insert”;

/**

  • 删除的RoutingKey

*/

public final static String HOTEL_DELETE_KEY = “hotel.delete”;

}

(3)声明队列交换机

hotel-demo中,定义配置类MqConfig,声明队列、交换机、绑定队列和交换机:

@Configuration

public class MqConfig {

/**

  • 定义交换机

  • @return

*/

@Bean

public TopicExchange topicExchange() {

return new TopicExchange(MqConstants.HOTEL_EXCHANGE, true, false);

}

/**

  • 定义新增或修改的队列

  • @return

*/

@Bean

public Queue insertQueue() {

return new Queue(MqConstants.HOTEL_INSERT_QUEUE, true);

}

/**

  • 定义删除的队列

  • @return

*/

@Bean

public Queue deleteQueue() {

return new Queue(MqConstants.HOTEL_DELETE_QUEUE, true);

}

/**

  • 绑定修改队列和交换机

  • @return

*/

@Bean

public Binding insertQueueBinding() {

return BindingBuilder.bind(insertQueue())

.to(topicExchange())

.with(MqConstants.HOTEL_INSERT_KEY);

}

/**

  • 绑定删除队列和交换机

  • @return

*/

@Bean

public Binding deleteQueueBinding() {

return BindingBuilder.bind(deleteQueue())

.to(topicExchange())

.with(MqConstants.HOTEL_DELETE_KEY);

}

}

2.4 发送MQ消息

当在hotel-admin中发生增、删、改业务中分别发送MQ消息:

要传入酒店的id给hotel-demo用于修改

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-gJKvMERH-1637401737223)(file://C:\Users\30287\Desktop\Java%E5%AD%A6%E4%B9%A0%E8%A7%86%E9%A2%91\day03-Docker\day07-Elasticsearch03%E8%AE%B2%E4%B9%89\assets\image-20210723221843816.png?lastModify=1637401493)]

@PostMapping

public void saveHotel(@RequestBody Hotel hotel){

// 新增酒店

hotelService.save(hotel);

// 发送MQ消息

rabbitTemplate.convertAndSend(HotelMqConstants.EXCHANGE_NAME, HotelMqConstants.INSERT_KEY, hotel.getId());

}

@PutMapping()

public void updateById(@RequestBody Hotel hotel){

if (hotel.getId() == null) {

throw new InvalidParameterException(“id不能为空”);

}

hotelService.updateById(hotel);

// 发送MQ消息

rabbitTemplate.convertAndSend(HotelMqConstants.EXCHANGE_NAME, HotelMqConstants.INSERT_KEY, hotel.getId());

}

@DeleteMapping(“/{id}”)

public void deleteById(@PathVariable(“id”) Long id) {

hotelService.removeById(id);

// 发送MQ消息

rabbitTemplate.convertAndSend(HotelMqConstants.EXCHANGE_NAME, HotelMqConstants.DELETE_KEY, id);

}

2.5 接受MQ消息

hotel-demo接收到MQ消息要做的事情包括:

  • 新增消息:根据传递的hotel的id查询hotel信息,然后新增一条数据到索引库

  • 删除消息:根据传递的hotel的id删除索引库中的一条数据

(1)首先在hotel-democn.itcast.hotel.service包下的IHotelService中新增新增、删除业务

void deleteById(Long id);

void insertById(Long id);

(2)给hotel-demo中的cn.itcast.hotel.service.impl包下的HotelService中实现业务:

@Override

public void deleteById(Long id) {

try {

// 1.准备Request

DeleteRequest request = new DeleteRequest(“hotel”, id.toString());

// 2.发送请求

client.delete(request, RequestOptions.DEFAULT);

} catch (IOException e) {

throw new RuntimeException(e);

自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数Java工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年Java开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。img

既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Java开发知识点,真正体系化!

由于文件比较大,这里只是将部分目录截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且会持续更新!

如果你觉得这些内容对你有帮助,可以扫码获取!!(备注Java获取)

img

写在最后

为了这次面试,也收集了很多的面试题!

以下是部分面试题截图

Java程序员秋招三面蚂蚁金服,我总结了所有面试题,也不过如此
《一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码》点击传送门即可获取!

如果你觉得这些内容对你有帮助,可以扫码获取!!(备注Java获取)

img

写在最后

为了这次面试,也收集了很多的面试题!

以下是部分面试题截图

[外链图片转存中…(img-8TweuRxe-1712070631858)]
《一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码》点击传送门即可获取!

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/空白诗007/article/detail/750642
推荐阅读
相关标签
  

闽ICP备14008679号