Spring Spring-data-redis 实现的消息队列

配置环境

版本信息:

Spring 4.2.8.RELEASE(其中囊括tx、webmvc、context、aop之类的)
Spring-data-jpa 1.10.5.RELEASE
Spring-data-redis 1.8.0.RELEASE
Spring-data-commons 1.12.5.RELEASE
MySQL 5.7
JDK 1.8

Maven依赖：

<!-- spring begin --><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>4.2.8.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-aop</artifactId><version>4.2.8.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jms</artifactId><version>4.2.8.RELEASE</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjrt</artifactId><version>1.8.9</version></dependency><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-jpa</artifactId><version>1.10.5.RELEASE</version></dependency><!-- spring end --><!-- redis start--><dependency><groupId>org.springframework.data</groupId><artifactId>spring-data-redis</artifactId><version>1.8.0.RELEASE</version></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version></dependency><!--redis end-->

ApplicationContext.xml 配置

这里就只添加 Redis 相关的信息了。

<!-- 事务管理器 --><bean id="MytransactionManager"          class="org.springframework.orm.jpa.JpaTransactionManager"><property name="entityManagerFactory" ref="MyentityManagerFactory" /><property name="dataSource" ref="MydataSource"/></bean><!-- 注解式事务 --><tx:annotation-driven transaction-manager="MytransactionManager" /><!--MessageQueue Start--><bean id="MQConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"p:hostName="127.0.0.1" p:port="6379" p:password="password" p:usePool="true"></bean><bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"p:connectionFactory-ref="MQConnectionFactory"/><!--JDK序列化工具--><bean id="Serialization" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" /><!--文本序列化工具--><bean id="Stringserialization" class="org.springframework.data.redis.serializer.StringRedisSerializer" /><!--订阅者--><bean id="Listener" class="com.MuNineyi.messagequeue.Listener"/><!--订阅者适配器--><bean id="MessageListenerAdapter" class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter"><property name="serializer" ref="Serialization" /><property name="stringSerializer" ref="Stringserialization"/><property name="delegate" ref="Listener" /> <!--订阅者/目的地--><property name="defaultListenerMethod" value="receiveMessage"/> <!--默认接收方法--></bean><!--channelPattern 通道设置器，这里和老版本是不同的--><bean id="Topic" class="org.springframework.data.redis.listener.PatternTopic" beans:pattern="identity"/><!--装箱，这里和老版本是不同的--><bean id="RedisMessageListenerContainer" class="org.springframework.data.redis.listener.RedisMessageListenerContainer"><property name="connectionFactory" ref="MQConnectionFactory"/><property name="topicSerializer" ref="Stringserialization"/> <!--通道序列化--><property name="messageListeners"><map key-type="org.springframework.data.redis.connection.MessageListener" value-type="org.springframework.data.redis.listener.PatternTopic"><entry key-ref="MessageListenerAdapter"  value-ref="Topic"/></map></property></bean><!--MessageQueue End-->

代码实现

消息传递类(消息实体)

public class Message{private String name;private String age;private String liveCity;//相关的 get、set 方法
}

Sender 发送者

这里可以写成接口的形式,方便调用

@Service("Service")
public class Sender{@Qualifier(value = "redisTemplate")private RedisTemplate redisTemplate;public void sendMessage(String channel, Serializable message) {redisTemplate.convertAndSend(channel, message);}public RedisTemplate getRedisTemplate() {return redisTemplate;}public void setRedisTemplate(RedisTemplate redisTemplate) {this.redisTemplate = redisTemplate;}public void getInformationFromOtherAPI(String name, String age, String liveCity) throws InterruptedException {Message message = new Message();message.setName(name);message.setAge(age);message.setLiveCity(liveCity);sendMessage("identity ", message);}
}

Listener 订阅者

@Service("Listener")
public class Listener{@Autowiredprivate MiddleService middleService;/*** 订阅者* @param message*/public void receiveMessage(Serializable message) {if (message instanceof Message){Message message = (Message) message;System.out.println(message.getName()+message.getAge()+message.getLiveCity());}}
}

简单的代码实现已经完成了

调用 getInformationFromOtherAPI(), 就可以实现将信息填入消息队列中。

下一篇会说一下由于JPA提交事务慢，导致消息队列找不到刚提交到数据库的信息的问题。

Spring Spring-data-redis 实现的消息队列相关推荐

什么鬼，面试官竟然让我用Redis实现一个消息队列！！？
GitHub 9.4k Star 的Java工程师成神之路 ,不来了解一下吗? GitHub 9.4k Star 的Java工程师成神之路 ,真的不来了解一下吗? GitHub 9.4k Star 的 ...
面试官竟让我用Redis实现一个消息队列！
来自公众号:Hollis >>>千人线上直播活动报名倒计时(今晚20:00): 从Oracle出发,走进GaussDB的世界众所周知,redis是一个高性能的分布式key-valu ...
thinkphp 实现redis简单的消息队列
thinkphp 实现redis简单的消息队列本章简单的实现.消息队列的入列和出列 1.入列,入列作为生产者,只管尽情的成产即可,无需考虑其他 (秒杀.抢购场景除外). 此次我们假如有十个用户进入队 ...
redis延迟消息队列不准时php,Redis实现延迟消息队列
消息队列是应用中常用的一个技术点,通常我们可以借助消息队列中间件来实现,但是并不是所有的情况下,都需要使用到MQ. 如果只需要实现简单的消息队列,那么借助Redis即可. 如果对消息有着严格的可靠性等 ...
使用 Redis Stream 实现消息队列
使用 Redis Stream 实现消息队列 Intro Redis 5.0 中增加了 Stream 的支持,利用 Stream 我们可以实现可靠的消息队列,并且支持一个消息被多个消费者所消费,可以很 ...
redis简单队列java_使用Redis的简单消息队列
redis简单队列java 在本文中,我们将使用列表命令将Redis用作简单的消息队列. 假设我们有一个允许用户上传照片的应用程序. 然后在应用程序中,我们以不同大小显示照片,例如Thumb,Medi ...
使用Redis的简单消息队列
在本文中,我们将使用列表命令将Redis用作简单的消息队列. 假设我们有一个允许用户上传照片的应用程序. 然后在应用程序中,我们以不同大小显示照片,例如Thumb,Medium和Large. 在第一个 ...
redis 消息队列过段时间不能下发_以Redis来谈消息队列
首先我先引入一个大家熟知的观点:Reids可以作为消息队列来使用 redis提供了两种方式来做消息队列,一种是生产者消费者模式,一种是发布订阅模式. 本篇文章将从异步,解耦,分布式,可靠四部分来探 ...
redis stream 实现消息队列
redis stream 实现消息队列 Redis5.0带来了Stream类型.从字面上看是流类型,但其实从功能上看,应该是Redis对消息队列(MQ,Message Queue)的完善实现. 基于r ...
redis list 实现消息队列多线程消费
redis list 实现消息队列多线程消费 redis list 实现消息队列多线程消费 redis list 实现消息队列多线程消费利用redis list 命令: Redis Brpop ...