大家好，又见面了，我是你们的朋友全栈君。
搭建RabbitMQ环境
Springboot整合RabbitMQ
1、添加整合依赖
代码语言：javascript复制<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>2、配置application.yml
提供者
1）创建交换机和队列
代码语言：javascript复制@Configuration //一般放在启动类同目录下，由spring容器管理
public class RabbitMQConfiguration {
public static final String FANOUT_NAME="goods_fanoutexchange";
private static final String QUEUE1="goods_queue1";
private static final String QUEUE2="goods_queue2";
/* * 声明队列 * */
@Bean
public Queue getQueue1(){
return new Queue(QUEUE1);
}
/* * 声明队列 * */
@Bean
public Queue getQueue2(){
return new Queue(QUEUE2);
}
/* * 声明交换机 * */
@Bean
public FanoutExchange getFanoutExchange(){
return new FanoutExchange(FANOUT_NAME);
}
/* * 将队列和交换机绑定 * @Bean注解：将方法的返回值直接注入到spring的容器中,并能够有效的通过将另一个方法名作为参数，获得对应方法的返回值。 * */
@Bean
public Binding getBinding1(Queue getQueue1,FanoutExchange getFanoutExchange){
return BindingBuilder.bind(getQueue1).to(getFanoutExchange);
}
@Bean
public Binding getBinding2(Queue getQueue2,FanoutExchange getFanoutExchange){
return BindingBuilder.bind(getQueue2).to(getFanoutExchange);
}
}2）注入rabbitmq模板对象，将消息放入队列中
代码语言：javascript复制@Service
public class GoodsServiceImpl implements IGoodsService {
@Autowired
private GoodsMapper goodsMapper;
@Autowired
private RabbitTemplate rabbitTemplate;
@Reference
private ISearchService searchService;
/* * 添加商品时： * 1、没有消息队列，通过调用搜索服务的方式，将商品信息同步到搜索库 * 2、通过消息队列，将消息放入队列中，搜索服务监听消息队列中的消息 * */
@Override
public int insertGoods(Goods goods) {
int result=goodsMapper.insert(goods);
//通过dubbo调用搜索服务，同步索引库
/*if (result>0){ searchService.insert(goods); }*/
//将添加商品的信息放入rabbitmq中，必须保证实体类序列化且存在id值
rabbitTemplate.convertAndSend(RabbitMQConfiguration.FANOUT_NAME,"",goods);
return result;
}
}消费者1
——将商品信息添加到搜索库中
代码语言：javascript复制@Component
public class RabbitMQListener {
@Autowired
private SolrClient solrClient;
@RabbitListener(queues = "goods_queue1")
public void handlerGoods(Goods goods){
System.out.println("搜索工程消费消息");
//接收mq中的消息
SolrInputDocument solrInputDocument=new SolrInputDocument();
solrInputDocument.addField("id",goods.getId());
solrInputDocument.addField("gname",goods.getGname());
solrInputDocument.addField("gimage",goods.getGimage());
solrInputDocument.addField("ginfo",goods.getGinfo());
solrInputDocument.addField("gsave",goods.getGsave());
//不能传入BigDecimal类型
solrInputDocument.addField("gprice",goods.getGprice().doubleValue());
try {
solrClient.add(solrInputDocument);
solrClient.commit();
} catch (Exception e) {
e.printStackTrace();
}
}
}消费者2
——生成freemarker静态页面
代码语言：javascript复制@Component
public class RabbitMQListener {
@Autowired
private Configuration configuration;
@Autowired
private HttpServletRequest request;
@RabbitListener(queues = "goods_queue2")
public void handlerGoodsItem(Goods goods){
String [] images=goods.getGimage().split("\|");
//通过模板生成商品静态页面
try {
System.out.println("详情工程消费消息");
//获取商品详情的模板对象
Template template = configuration.getTemplate("goodsItem.ftl");
String contextPath="";
try{
//request.getContextPath()可以返回当前页面所在的应用的名字(部署的项目名);
contextPath=request.getContextPath();
}catch (Exception e){
//利用catch捕获这个异常
// No thread-bound request found: Are you referring to request attributes outside of an actual web request,
// or processing a request outside of the originally receiving thread?
// If you are actually operating within a web request and still receive this message,
// your code is probably running outside of DispatcherServlet: In this case,
// use RequestContextListener or RequestContextFilter to expose the current request.
e.printStackTrace();
}
//准备商品数据
Map<String,Object> map=new HashMap<>();
map.put("goods",goods);
map.put("context",contextPath);
map.put("images",images);
//生成静态页
//获得classpath路径
String path = this.getClass().getResource("/static/page/").getPath() goods.getId() ".html";;
template.process(map,new FileWriter(path));
} catch (Exception e) {
e.printStackTrace();
}
}
}注意：通过监听触发的这个方法中，根据注入的request对象获取项目的根路径时异常。
补充
1、获取request对象 1）通过注解获取（推荐）：
代码语言：javascript复制public class GoodsController{
@Autowired
HttpServletRequest request; //这里可以获取到request
}2）spring自带的方式：
代码语言：javascript复制HttpServletRequest request = ((ServletRequestAttributes)RequestContextHolder.getRequestAttributes()).getRequest();需要配置RequestContextListener监听 普通的web项目(含web.xml)
代码语言：javascript复制<listener>
<listener-class>
org.springframework.web.context.request.RequestContextListener
</listener-class>
</listener>springboot项目(不含web.xml)
代码语言：javascript复制//启动类中
@Bean
public RequestContextListener requestContextListener(){
return new RequestContextListener();
}3）直接在参数中传递
代码语言：javascript复制public String getGoods(HttpServletRequest request)2、对request.getContextPath()的理解: ——是在开发Web项目时，经常用到的方法，是为了解决相对路径的问题，可返回站点的根路径。 比如：要生成一个文件放在服务器上得一个目录下,可以使用request.getContextPath() /dir,组成一个完整得目录结构！
当使用Tomcat作为Web服务器，项目一般部署在Tomcat下的webapps的目录下。具体来说主要用两种部署的路径：
（1）将web项目中的webRoot下的文件直接拷贝到webapps/ROOT下（删除ROOT下的原有文件）；
（2）在Tomcat下的webapps中创建以项目名称命名（当然也可以用其他的名称）的文件夹，并将webRoot下的文件直接拷贝到该文件夹下。
对于第一部署方法，request.getContextPath()的返回值为空（即：””,中间无空格，注意区分null)。
对于第二部署方法，其返回值为：/创建的文件夹的名称。
假定你的web application 名称为news,你在浏览器中输入请求路径：
http://localhost:8080/news/main/list.jsp
则执行下面向行代码后打印出如下结果：
1、 System.out.println(request.getContextPath());
打印结果：/news
2、System.out.println(request.getServletPath());
打印结果：/main/list.jsp
3、 System.out.println(request.getRequestURI());
打印结果：/news/main/list.jsp
4、 System.out.println(request.getRealPath(“/”));
打印结果：F:Tomcat 6.0webappsnewstest
request.getContextPath()可以返回当前页面所在的应用的名字;
request.getSchema()可以返回当前页面使用的协议，http 或是 https;
request.getServerName()可以返回当前页面所在的服务器的名字;
request.getServerPort()可以返回当前页面所在的服务器使用的端口,就是80;
实际应用中，一般用来解决jsp测试和生产环境路径不同的问题： <% String appContext = request.getContextPath(); String basePath =request.getScheme() ”: //” request.getServerName() ”:” request.getServerPort() appContext; %> 3、获取项目根路径的方式： //获取类加载的根路径(/classes) (1)this.getClass().getResource(“/”).getPath()； // 获取当前类的所在工程路径 this.getClass().getResource(“”).getPath()；
//获取类加载的根路径(/classes) (2)this.getClass().getClassLoader().getResource(“”)；
//获取当前项目路径 (3)System.getProperty(“user.dir”)；
//获取所有的类路径 包括jar包的路径 (4)System.getProperty(“java.class.path”)；
//获取类加载的根路径(/classes) (5)Thread.currentThread().getContentClassLoader().getResource(“”).getPath()；
//表示到项目的根目录下, 要是想到目录下的子文件夹,修改”/“即可 (6)request.getSession().getServletContext().getRealPath(”/”)；
发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/146335.html原文链接：https://javaforall.cn
