`

转-项目中用到rabbitmq的地方1之spring定时器

 
阅读更多

Spring的定时器

Spring定时器调用service层的接口方法

1.web.xml文件配置

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <web-app version="2.5"
  3. xmlns="http://java.sun.com/xml/ns/javaee"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
  6. http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
  8. <welcome-file-list>
  9. <welcome-file>index.jsp</welcome-file>
  10. </welcome-file-list>
  11. <!-- spring文件的加载 -->
  12. <context-param>
  13. <param-name>contextConfigLocation</param-name>
  14. <param-value>classpath:/spring.xml</param-value>
  15. </context-param>
  16. <listener>
  17. <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  18. </listener>
  19. <!-- struts2文件加载 -->
  20. <filter>
  21. <filter-name>struts2</filter-name>
  22. <filter-class>org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter</filter-class>
  23. </filter>
  24. <filter-mapping>
  25. <filter-name>struts2</filter-name>
  26. <url-pattern>*.do</url-pattern>
  27. </filter-mapping>
  28. <filter-mapping>
  29. <filter-name>struts2</filter-name>
  30. <url-pattern>*.jsp</url-pattern>
  31. </filter-mapping>
  33. <filter>
  34. <filter-name>encodingFilter</filter-name>
  35. <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
  36. <init-param>
  37. <param-name>encoding</param-name>
  38. <param-value>UTF-8</param-value>
  39. </init-param>
  40. <init-param>
  41. <param-name>forceEncoding</param-name>
  42. <param-value>true</param-value>
  43. </init-param>
  44. </filter>
  45. <filter-mapping>
  46. <filter-name>encodingFilter</filter-name>
  47. <url-pattern>/*</url-pattern>
  48. </filter-mapping>
  49. </web-app> 
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" 
	xmlns="http://java.sun.com/xml/ns/javaee" 
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
	http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
	
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
  <!-- spring文件的加载 -->
  <context-param>
  	<param-name>contextConfigLocation</param-name>
  	<param-value>classpath:/spring.xml</param-value>
  </context-param>
  <listener>
  	<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
  <!-- struts2文件加载 -->
	<filter>
	  <filter-name>struts2</filter-name>
	  <filter-class>org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter</filter-class>
	 </filter>
	 <filter-mapping>
	  <filter-name>struts2</filter-name>
	  <url-pattern>*.do</url-pattern>
	 </filter-mapping>
	 <filter-mapping>
		  <filter-name>struts2</filter-name>
		  <url-pattern>*.jsp</url-pattern>
	  </filter-mapping>
	  
	   <filter>
		  <filter-name>encodingFilter</filter-name>
		  <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
		  <init-param>
		   <param-name>encoding</param-name>
		   <param-value>UTF-8</param-value>
		  </init-param>
		  <init-param>
		   <param-name>forceEncoding</param-name>
		   <param-value>true</param-value>
		  </init-param>
		 </filter>
		 <filter-mapping>
		  <filter-name>encodingFilter</filter-name>
		  <url-pattern>/*</url-pattern>
		 </filter-mapping>
</web-app>

 

2.spring.xml文件配置也就是spring的核心配置文件

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="<a href="http://www.springframework.org/schema/beans">http://www.springframework.org/schema/beans</a>"
  3. xmlns:xsi="<a href="http://www.w3.org/2001/XMLSchema-instance">http://www.w3.org/2001/XMLSchema-instance</a>"
  4. xmlns:tx="<a href="http://www.springframework.org/schema/tx">http://www.springframework.org/schema/tx</a>"
  5. xmlns:aop="<a href="http://www.springframework.org/schema/aop">http://www.springframework.org/schema/aop</a>"
  6. xsi:schemaLocation="<a href="http://www.springframework.org/schema/beans">http://www.springframework.org/schema/beans</a> <a href="http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">http://www.springframework.org/schema/beans/spring-beans-2.5.xsd</a>
  7. <a href="http://www.springframework.org/schema/tx">http://www.springframework.org/schema/tx</a> <a href="http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">http://www.springframework.org/schema/tx/spring-tx-2.5.xsd</a>
  8. <a href="http://www.springframework.org/schema/aop">http://www.springframework.org/schema/aop</a> <a href="http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">http://www.springframework.org/schema/aop/spring-aop-2.5.xsd</a>">
  9. <bean id="sessionFactory"
  10. class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
  11. <property name="configLocation"
  12. value="classpath:hibernate.cfg.xml">
  13. </property>
  14. </bean>
  15. <!--调用service的接口的方法让他定时执行，必须的文件 -->
  16. <bean class="com.guoxin.util.MyApplicationContextUtil"></bean>
  17. <import resource="spring_BlockAction.xml"/>
  18. <import resource="spring_BlockDao.xml"/>
  19. <import resource="spring_BlockService.xml"/>
  20. <import resource="scheduler.xml"/>
  21. </beans> 
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:tx="http://www.springframework.org/schema/tx"
 xmlns:aop="http://www.springframework.org/schema/aop"
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd">
 <bean id="sessionFactory"
  class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
  <property name="configLocation"
   value="classpath:hibernate.cfg.xml">
  </property>
 </bean>
 <!--调用service的接口的方法让他定时执行，必须的文件  -->
 <bean class="com.guoxin.util.MyApplicationContextUtil"></bean>
    <import resource="spring_BlockAction.xml"/>
 <import resource="spring_BlockDao.xml"/>
 <import resource="spring_BlockService.xml"/>
    <import resource="scheduler.xml"/>
</beans>

3.spring_BlockAction.xml文件配置

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"
  4. xsi:schemaLocation="
  5. http://www.springframework.org/schema/beans
  6. http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
  8. <bean id="blockAction"class="com.guoxin.action.BlockAction">
  9. <property name="blockservice">
  10. <ref bean="blockService"/>
  11. </property>
  12. </bean>
  13. </beans> 
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"
	xsi:schemaLocation="
		http://www.springframework.org/schema/beans 
		http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">

	<bean id="blockAction" class="com.guoxin.action.BlockAction">
		<property name="blockservice">
			<ref bean="blockService"/>
		</property>
	</bean>
</beans>

 

4.spring_BlockDao.xml文件配置

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans
  3. xmlns="http://www.springframework.org/schema/beans"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
  6. <bean id="blockDao"class="com.guoxin.dao.GetBlockUrlImp">
  7. <property name="sessionFactory">
  8. <ref bean="sessionFactory"/>
  9. </property>
  10. </bean>
  11. </beans> 
<?xml version="1.0" encoding="UTF-8"?>
<beans
	xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
<bean id="blockDao" class="com.guoxin.dao.GetBlockUrlImp">
		<property name="sessionFactory">
			<ref bean="sessionFactory"/>
		</property>
	</bean>
</beans>

 

5.spring_BlockService.xml文件配置

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"
  4. xsi:schemaLocation="
  5. http://www.springframework.org/schema/beans
  6. http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
  7. <bean id="blockService"class="com.guoxin.service.GetBlockUrlServiceImp">
  8. <property name="blockdao">
  9. <ref bean="blockDao"/>
  10. </property>
  11. </bean>
  12. </beans> 
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws"
	xsi:schemaLocation="
		http://www.springframework.org/schema/beans 
		http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
    <bean id="blockService" class="com.guoxin.service.GetBlockUrlServiceImp">
		<property name="blockdao">
			<ref bean="blockDao"/>
		</property>
	</bean>
</beans>

 

6.struts.xml文件配置

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE struts PUBLIC
  3. "-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"
  4. "http://struts.apache.org/dtds/struts-2.0.dtd">
  6. <struts>
  8. <include file="Block.xml"></include>
  9. </struts> 
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE struts PUBLIC
    "-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"
    "http://struts.apache.org/dtds/struts-2.0.dtd">

<struts>

<include file="Block.xml"></include>
</struts>

 

7.Block.xml文件配置

Java代码 复制代码 收藏代码
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE struts PUBLIC
  3. "-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"
  4. "http://struts.apache.org/dtds/struts-2.0.dtd">
  6. <struts>
  7. <constant name="struts.i18n.encoding" value="UTF-8" />
  8. <package name="default"extends="struts-default">
  9. <action name="blockaction"class="blockAction" method="test">
  10. <result name="success">/MyJsp2.jsp</result>
  11. </action>
  12. </package>
  13. </struts> 
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE struts PUBLIC
    "-//Apache Software Foundation//DTD Struts Configuration 2.0//EN"
    "http://struts.apache.org/dtds/struts-2.0.dtd">

<struts>
<constant name="struts.i18n.encoding" value="UTF-8" />
<package name="default" extends="struts-default">
		<action name="blockaction" class="blockAction" method="test">
			<result name="success">/MyJsp2.jsp</result>
		</action>
	</package>
</struts>

 

8.主要代码

Java代码 复制代码 收藏代码
  1. package com.guoxin.util;
  3. import org.springframework.beans.BeansException;
  4. import org.springframework.context.ApplicationContext;
  5. import org.springframework.context.ApplicationContextAware;
  6. publicclass MyApplicationContextUtil implements ApplicationContextAware {
  8. privatestatic ApplicationContext context;
  10. // 声明一个静态变量保存
  11. publicvoid setApplicationContext(ApplicationContext contex) throws BeansException {
  12. context = contex;
  13. }
  15. publicstatic ApplicationContext getContext() {
  16. return context;
  17. }
  18. } 
package com.guoxin.util;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
public class MyApplicationContextUtil implements ApplicationContextAware {

	private static ApplicationContext context;

	// 声明一个静态变量保存
	public void setApplicationContext(ApplicationContext contex) throws BeansException {
		context = contex;
	}

	public static ApplicationContext getContext() {
		return context;
	}
}

 

Java代码 复制代码 收藏代码
  1. package com.guoxin.util;
  3. import java.util.List;
  5. import org.quartz.JobExecutionContext;
  6. import org.quartz.JobExecutionException;
  7. import org.springframework.scheduling.quartz.QuartzJobBean;
  9. import com.guoxin.bean.Block;
  10. import com.guoxin.service.Iservice.GetBlockUrlService;
  11. import com.rabbitmq.client.Channel;
  12. import com.rabbitmq.client.Connection;
  13. import com.rabbitmq.client.ConnectionFactory;
  14. import com.rabbitmq.client.MessageProperties;
  15. import com.sun.codemodel.JNullType;
  17. @SuppressWarnings("deprecation")
  18. publicclass DMSMethod extends QuartzJobBean{
  19. private GetBlockUrlService blockservice;//调用service层的接口
  21. public DMSMethod(){
  22. blockservice = (GetBlockUrlService)MyApplicationContextUtil.getContext().getBean("blockService");
  23. }
  26. protectedvoid executeInternal(JobExecutionContext arg0)
  27. throws JobExecutionException {
  28. try {
  29. //获得静态版块的链接
  30. List<Block> staticList=blockservice.queryBlockUrlStatic();
  31. for(Block block:staticList){
  32. String task=block.getBlock_url();
  33. System.out.println("静态："+task);
  34. }
  35. } catch (Exception e) {
  36. // TODO: handle exception
  37. e.printStackTrace();
  38. }
  39. System.out.println("执行..........");
  41. }
  43. public GetBlockUrlService getBlockservice() {
  44. return blockservice;
  45. }
  46. } 
package com.guoxin.util;

import java.util.List;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;

import com.guoxin.bean.Block;
import com.guoxin.service.Iservice.GetBlockUrlService;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;
import com.sun.codemodel.JNullType;

@SuppressWarnings("deprecation")
public class DMSMethod extends QuartzJobBean{
	private GetBlockUrlService blockservice;//调用service层的接口
	
	public DMSMethod(){
	   blockservice = (GetBlockUrlService)MyApplicationContextUtil.getContext().getBean("blockService");
	}


	protected void executeInternal(JobExecutionContext arg0)
			throws JobExecutionException {
		try {
    			//获得静态版块的链接
			List<Block> staticList=blockservice.queryBlockUrlStatic();
			for(Block block:staticList){
		    	  String task=block.getBlock_url();
		       	  System.out.println("静态："+task);
		    	}
			    	} catch (Exception e) {
			// TODO: handle exception
    		e.printStackTrace();
		}
		System.out.println("执行..........");
		
	}

	public GetBlockUrlService getBlockservice() {
		return blockservice;
	}
}

 

Java代码 复制代码 收藏代码
  1. package com.guoxin.service;
  3. import java.util.List;
  5. import com.guoxin.bean.Block;
  6. import com.guoxin.dao.Idao.GetBlockUrl;
  7. import com.guoxin.service.Iservice.GetBlockUrlService;
  9. publicclass GetBlockUrlServiceImp implements GetBlockUrlService {
  10. private GetBlockUrl blockdao;
  11. public List<Block> queryBlockUrlStatic() {
  12. List<Block> list=blockdao.queryBlockUrlStatic();
  13. return list;
  14. }
  15. public List<Block> queryBlockUrlTrends() {
  16. List<Block> list=blockdao.queryBlockUrlStatic();
  17. return list;
  18. }
  19. public GetBlockUrl getBlockdao() {
  20. return blockdao;
  21. }
  22. publicvoid setBlockdao(GetBlockUrl blockdao) {
  23. this.blockdao = blockdao;
  24. }
  26. }
分享到：
| 转-项目中用到rabbitMQ的地方2
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    Java开发案例-springboot-06-整合RabbitMQ-源代码+文档.rar

    Java开发案例-springboot-06-整合RabbitMQ-源代码+文档.rar Java开发案例-springboot-06-整合RabbitMQ-源代码+文档.rar Java开发案例-springboot-06-整合RabbitMQ-源代码+文档.rar Java开发案例-springboot-06-整合...

    spring-boot-mq-rabbitmq 一套打通rabbitmq 打开可用 有注释

    spring.rabbitmq.host=your-rabbitmq-host spring.rabbitmq.port=your-rabbitmq-port spring.rabbitmq.username=your-username spring.rabbitmq.password=your-password ``` 或者使用YAML格式： ```yaml # ...

    rabbitmq-server-3.11.13

    rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-3.11.13rabbitmq-server-...

    RabbitMq与Spring整合实例

    1. **配置依赖**：在项目的`pom.xml`文件中添加RabbitMQ的Spring整合依赖。如： ```xml &lt;groupId&gt;org.springframework.amqp &lt;artifactId&gt;spring-rabbit &lt;version&gt;2.3.7 ``` 确保版本号与你的Spring框架版本兼容...

    rabbitmq-c-master.rar_RabbitMQ c lib_cmake编译_rabbitmq_rabbitmq-c

    1. **获取源码**：首先，从官方仓库或者提供的压缩包中下载`rabbitmq-c-master`源代码。 2. **创建构建目录**：为了保持源代码的整洁，我们通常在源代码目录外创建一个新目录，例如`build`，用于放置编译生成的文件...

    rabbitmq 3.6.5-1离线安装

    rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm systemctl status rabbitmq-server systemctl start rabbitmq-server systemctl stop rabbitmq-server systemctl restart rabbitmq-server systemctl enable ...

    RabbitMQ-c源码

    **RabbitMQ-c源码分析** RabbitMQ-c是一个轻量级且高效的C语言实现的RabbitMQ客户端库。RabbitMQ是一个开源的消息代理和队列服务器，它使用AMQP（Advanced Message Queuing Protocol）协议，广泛应用于分布式系统中...

    158-最简单的 RabbitMQ 监控方法1

    在安装了RabbitMQ的服务器上执行`rabbitmq-plugins enable rabbitmq_management`命令即可启用。接着，需要创建一个用户，例如`user_admin`，并设置相应的权限，以便登录管理控制台。 一旦登录Web控制台，最需要注意...

    rabbitmq spring demo

    rabbitmq spring rabbitmq spring rabbitmq spring rabbitmq spring http://knight-black-bob.iteye.com/blog/2304089

    rabbitmq-server-3.5.4.tar.gz

    1. **下载**：首先，你需要从官方网站下载适合你的Linux发行版的RabbitMQ版本，如"rabbitmq-server-generic-unix-3.5.4.tar.gz"。你可以使用wget命令或者直接在浏览器中下载。 2. **解压**：使用tar命令解压下载的...

    rabbitmq-server-3.7.3百度网盘下载.txt

    这里提供了rabbitmq-server-3.7.3.exe百度网盘下载,官网下载实在是太慢了,亲测有效! rabbitmq-server-3.7.3.exe rabbitmq-server-3.7.3.exe rabbitmq-server-3.7.3.exe

    spring-cloud-steam-rabbitmq-demo.zip

    在“spring-cloud-steam-rabbitmq-demo”项目中，我们将了解以下几个关键知识点： 1. **配置Spring Cloud Stream**： 首先，我们需要在`application.yml`或`application.properties`中配置RabbitMQ的相关信息，...

    rabbitmq-server-generic-unix-3.6.1.tar

    标题中的“rabbitmq-server-generic-unix-3.6.1.tar”是指RabbitMQ服务器的3.6.1版本的通用Unix安装包。RabbitMQ是一个开源的消息代理和队列服务器，广泛应用于分布式系统中，用于处理异步任务、消息传递和负载均衡...

    rabbitmq4.0.2离线安装

    rpm -ivh rabbitmq-server-4.0.2-1.el8.noarch.rpm systemctl status rabbitmq-server systemctl start rabbitmq-server systemctl stop rabbitmq-server systemctl restart rabbitmq-server systemctl enable ...

    java队列源码-rabbitmq-repository:RabbitMQ消息队列学习的源码记录

    rabbitmq-spring-topic-exchange rabbitmq主题示例 rabbitmq-java-rpc rabbitmq PRC通信示例 rabbitmq-spring-helloworld spring boot 使用rabbitmq的第一个demo rabbitmq-spring-work-queue spring boot使用...

    RabbitMQ快速入门及API介绍（401M）

    【课程目录】：---第一章：RabbitMQ介绍----1-什么是消息中间件.mp4----2-RabbitMQ消息队列安装：window环境.mp4----3-RabbitMQ消息队列安装 ：Linux环境.mp4----4-Rabbitmq入口示例：server.mp4----5-rabbitmq入口...

    rabbitmq-server-3.6.1

    rabbitmq-server-3.6.1 的安装程序，rabbitmq-server-3.6.1 安装 rabbitmq-server

    最新版windows rabbitmq-server-3.8.5.zip

    2. **安装与配置**：`rabbitmq-server-3.8.5.exe`是RabbitMQ Windows版的安装程序，用户可以通过这个可执行文件进行安装。安装过程中会涉及服务启动设置、端口配置（默认5672用于AMQP，15672用于管理界面）、环境...

    windows服务----基于RabbitMQ

    为了与RabbitMQ进行交互，我们需要使用RabbitMQ的C#客户端库，这可以通过NuGet包管理器添加到项目中。该库提供了创建连接、通道、声明交换机和队列，以及接收和发送消息的功能。在这个场景中，服务会在启动时建立...

    docker-compose部署单机rabbitmq

    docker-compose部署单机rabbitmq，一键启动

Magicbox
Global site tag (gtag.js) - Google Analytics