Spring boot+redis实现消息发布与订阅的代码_Redis

来源:脚本之家  责任编辑:小易  

在application.properties或者application.yml中配置即可,类似例如在properties文件中配置logging.pattern.console=gray(%date{yyyy-MM-dd HH:mm:ss:SSS})|%highlight(%-5level)|%red(%thread)|%boldYellow(%logger)|%msg%nwww.zgxue.com防采集请勿采集本网。

一.创建spring boot项目

Spring Boot 将“以约定代替配置(Convention Over Configuration)”的原则发挥到了极致,进一步提升易用性。Spring Cloud 利用 Netflix 的开源组件解决了与云原生应用开发相关的问题,如服务注册、服务

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.41</version> </dependency>

JHipster:基于Spring Boot与AngularJS应用程序的Yeoman源代码生成器。官网 JRebel:无需重新部署,可以即时重新加载代码与配置的商业软件。官网 Lombok:减少冗余的代码生成器。官网 Spring Loaded:类

二.编辑yml配置文件

26个字母在单词中的发音发音表如下。1、A、B、C、D、E这5个字母的发音如下。2、F、G、H、I、J这5个字母的发音如下。3、K、L、M、N、O这5个字母的发音如下。4、P、Q、R、S、T这5个字母的发音如下

server: port: 7888# 日志配置logging: config: classpath:log/logback.xml level: cn.com.dhcc: info org.springframework: info org.springframework.web: info com.alibaba.nacos.client.naming: errorspring: redis: host: localhost port: 6379 password: ********* database: 1 jedis: pool: max-idle: 8 max-active: 8 max-wait: -1 min-idle: 0 timeout: 5000

Cauliflower 白花菜 Spring onions 葱 Garlic 大蒜 Ginger 姜 Chinese leaves 大白菜 Leeks 大葱 Mustard&cress 芥菜苗 Green Pepper 青椒 Red pepper 红椒 Yellow pepper 黄椒 Mushroom 洋菇 Broccoli

三.配置Redis

7.小城之春 Spring in a Small Town(1948)(中国) 一部典型的心理抒情片 世界电影史上不可多得的艺术珍品 开创了中国电影史上诗化电影的先河 8.罗生门 Rash?mon(1950)(日本) 挖掘人性丑恶的巅峰之

@Configurationpublic class RedisConfiguration { /** * 实例化 RedisTemplate 对象 * * @return */ @Bean("RedisTemplateS") public RedisTemplate<String, Object> functionDomainRedisTemplate(RedisConnectionFactory redisConnectionFactory) { RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); initDomainRedisTemplate(redisTemplate, redisConnectionFactory); return redisTemplate; } /** * 设置数据存入 redis 的序列化方式,并开启事务 * * @param redisTemplate * @param factory */ private void initDomainRedisTemplate(@Qualifier("RedisTemplateS") RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) { // 如果不配置Serializer,那么存储的时候缺省使用String,如果用User类型存储,那么会提示错误User can't cast to // String! redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setHashKeySerializer(new StringRedisSerializer()); FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<Object>(Object.class); redisTemplate.setHashValueSerializer(fastJsonRedisSerializer); redisTemplate.setValueSerializer(fastJsonRedisSerializer); //redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); //redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // 开启事务 redisTemplate.setEnableTransactionSupport(true); redisTemplate.setConnectionFactory(factory); } /** * 注入封装RedisTemplate @Title: redisUtil @return RedisUtil @date * */ @Bean(name = "redisUtils") public RedisUtils redisUtil(@Qualifier("RedisTemplateS") RedisTemplate<String, Object> redisTemplate) { RedisUtils redisUtil = new RedisUtils(); redisUtil.setRedisTemplate(redisTemplate); return redisUtil; }

四.编写RedisUtil消息发布方法

public class RedisUtils { private static final Logger log = LoggerFactory.getLogger(RedisUtils.class); private RedisTemplate<String, Object> redisTemplate; public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) { this.redisTemplate = redisTemplate; } public void publish(String channal ,Object obj) { redisTemplate.convertAndSend(channal,obj ); }}

五.配置消息监听

@Configurationpublic class RedisMessageListener { /** * 创建连接工厂 * @param connectionFactory * @param listenerAdapter * @return */ @Bean public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter,MessageListenerAdapter listenerAdapter2){ RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); //接受消息的key container.addMessageListener(listenerAdapter,new PatternTopic("phone")); return container; } /** * 绑定消息监听者和接收监听的方法 * @param receiver * @return */ @Bean public MessageListenerAdapter listenerAdapter(ReceiverRedisMessage receiver){ return new MessageListenerAdapter(receiver,"receiveMessage"); } /** * 注册订阅者 * @param latch * @return */ @Bean ReceiverRedisMessage receiver(CountDownLatch latch) { return new ReceiverRedisMessage(latch); } /** * 计数器,用来控制线程 * @return */ @Bean public CountDownLatch latch(){ return new CountDownLatch(1);//指定了计数的次数 1 }}

六.消息订阅方法

public class ReceiverRedisMessage { private static final Logger log = LoggerFactory.getLogger(ReceiverRedisMessage.class); private CountDownLatch latch; @Autowired public ReceiverRedisMessage(CountDownLatch latch) { this.latch = latch; } /** * 队列消息接收方法 * * @param jsonMsg */ public void receiveMessage(String jsonMsg) { log.info("[开始消费REDIS消息队列phone数据...]"); try { log.info("监听者收到消息:{}", jsonMsg); JSONObject exJson = JSONObject.parseObject(jsonMsg); User user = JSON.toJavaObject(exJson, User.class); System.out.println("转化为对象 :"+user); log.info("[消费REDIS消息队列phone数据成功.]"); } catch (Exception e) { log.error("[消费REDIS消息队列phone数据失败,失败信息:{}]", e.getMessage()); } latch.countDown(); }}

七.定时消息发布测试

@EnableScheduling@Componentpublic class PublisherController { private static final Logger log = LoggerFactory.getLogger(PublisherController.class); @Autowired private RedisUtils redisUtils; @Scheduled(fixedRate = 5000) public String pubMsg() { User user=new User(1, "尚***", 26,"男","陕西省xxxx市xxxxxx县"); redisUtils.publish("phone", user); log.info("Publisher sendes Topic... "); return "success"; }}

八.测试结果

九.发布对象User实体

public class User implements Serializable { /** * */ private static final long serialVersionUID = 1L; private int id; private String name; private int age; private String sex; private String address; .....................}

到此这篇关于Spring boot+redis实现消息发布与订阅的文章就介绍到这了,更多相关Spring boot redis消息发布与订阅内容请搜索真格学网以前的文章或继续浏览下面的相关文章希望大家以后多多支持真格学网!

转自:IntelliJ IDEA必装插件以及SpringBoot使IntelliJ IDEA必装插件有不知道怎么安装的吗?File->settings打开设置面板,找到plugins,输入想要安装的插件回车即可。plugins面板1.背景图片目前,IDEA支持设置背景图片。这对于广大程序员来说无疑是个好功能。整日对着枯燥的代码实在是会让人疲乏。要是可以设置一张美女图片的话。设置方法:Ctrl+Shift+A(或者help->find action)调用弹窗后输入Set Background Image。在里面设定要设置为Image的图片,透明度调到15左右,保存即可。效果如图:2.Maven Helper日常开发中,可能经常会遇到jar包冲突等问题,就需要通过查看maven依赖树来查看依赖情况。这种方式不是很高效,这里推荐一个插件,安装之后,直接打开pom文件,即可查看依赖数,还能自动分析是否存在jar包冲突。一旦安装了Maven Helper插件,只要打开pom文件,就可以打开该pom文件的Dependency Analyzer视图(在文件打开之后,文件下面会多出这样一个tab)。进入Dependency Analyzer视图之后有三个查看选项分别是:Conflicts(冲突)All Dependencies as List(列表形式查看所有依赖)All Dependencies as Tree(树结构查看所有依赖),并且这个页面还支持搜索。3.FindBugs-IDEAFindBugs很多人都并不陌生,Eclipse中有插件可以帮助查找代码中隐藏的bug,IDEA中也有这款插件。使用方法很简单,就是可以对多种级别的内容进行finbugs。分析完之后会有一个视图进行提示,详细的说明是哪种问题。4.阿里巴巴代码规约检测检测JAVA代码中存在不规范得位置然后给予提示,阿里巴巴规约插件包含三个子菜单:编码规约扫描、关闭试试检测功能。安装好此插件即可自动在不规范位置给与提示。5.GsonFormatJava开发中,经常有把json格式的内容转成Object的需求,比如项目开始时,合作方给你提供了一个json格式request/response,这时候你就需要将其定义成一个Java类,GsonFormat这款插件可以实现该功能。6.Lombok plugin在Java中,我们经常会定义很多JavaBean,这些Bean需要有getter、setter、toString、equals和hashCode等方法。通常情况下,我们可以使用IDEA的快捷键生成这些代码,但是自动生成的代码后,如果bean中的属性一旦有修改,需要重新生成,给代码维护增加了一定的负担。有一款很好的插件,可以帮助开发者节省这部分工作。那就是Lombok。只要在IDEA中安装了该插件,只需要在JavaBean中添加一行注解代码,插件就会自动帮我们生成getter、setter、toString、equals和hashCode等方法。当然,这些方法不止在IDE中的代码调用中需要用到,在真正线上部署的时候也需要有,所以,还需要使用maven引入一个lombok的包。Data class Wechat {private String id;private String desc;}我们在Wechat类上面添加了@Data注解,插件就自动帮我们添加了getter/setter和toString方法。7.String Manipulation字符串日常开发中经常用到的,但是不同的字符串类型在不同的地方可能有一些不同的规则,比如类名要用驼峰形式、常量需要全部大写等,有时候还需要进行编码解码等。这里推荐一款强大的字符串转换工具—String Manipulation。它强大到什么程度,看下他的功能列表你就知道了:安装好插件后,选中需要处理的内容后,按快捷键Alt+m,即可弹出工具功能列表。很好很强大的一款字符串处理工具。8.Mybatis plugin目前ORM框架中,Mybatis非常受欢迎。但是,同时给很多开发带来困扰的就是Mybatis需要很多xml的配置文件,有的时候很难去进行修改。这里推荐一款神器,可以让你像编辑java代码一样编辑mybatis的文件。Intellij Idea Mybatis插件主要功能:提供Mapper接口与配置文件中对应SQL的导航编辑XML文件时自动补全根据Mapper接口,使用快捷键生成xml文件及SQL标签ResultMap中的property支持自动补全,支持级联(属性A.属性B.属性C)快捷键生成@Param注解XML中编辑SQL时,括号自动补全XML中编辑SQL时,支持参数自动补全(基于@Param注解识别参数)自动检查Mapper XML文件中ID冲突自动检查Mapper XML文件中错误的属性值支持Find Usage支持重构从命名支持别名自动生成ResultMap属性(图源:https://www.oschina.net/p/intellij-mybatis-plugin)但是这款插件是收费的,但是不影响他确实是一个很实用,可以很大程度上提升开发效率的插件。读者可以考虑使用Free Mybatis plugin(这款插件我没用过,具体是否好用有待考证)。9.Key promoter X对于很多刚刚开始使用IDEA的开发者来说,最苦恼的就是不知道快捷键操作是什么。使用IDEA,如果所有操作都使用鼠标,那么说明你还不是一个合格的程序员。这里推荐一款可以进行快捷键提示的插件Key promoter X。Key Promoter X 是一个提示插件,当你在IDEA里面使用鼠标的时候,如果这个鼠标操作是能够用快捷键替代的,那么Key Promoter X会弹出一个提示框,告知你这个鼠标操作可以用什么快捷键替代。当我使用鼠标查看一个方法都被哪些类使用的时候,就会提示:记住这个快捷键以后,就可以使用快捷键代替鼠标啦。10.activate-power-mode最后,介绍一款程序员很好的在妹子面前装X的插件—activate-power-mode。安装了这款插件之后,你写代码的时候,就会附加一些狂拽炫酷屌炸天的效果11.ignoregit提交时过滤掉不需要提交的文件,很方便,有些本地文件是不需要提交到Git上的。12.CamelCase将不是驼峰格式的名称,快速转成驼峰格式,安装好后,选中要修改的名称,按快捷键shift+alt+u。13.CodeGlance在编辑区的右侧显示的代码地图。14.Material Theme UI这是一款主题插件,可以让你的ide的图标变漂亮,配色搭配的很到位,还可以切换不同的颜色,甚至可以自定义颜色。默认的配色就很漂亮了,如果需要修改配色,可以在工具栏中Tools->Material Theme然后修改配色等。15.Background image Plus这是一款可以设置idea背景图片的插件,不但可以设置固体的图片,还可以设置一段时间后随机变化背景图片,以及设置图片的透明度等等。16.#Rainbow Brackets彩虹颜色的括号 看着很舒服 敲代码效率变高SpringBoot|番外:使用小技巧合集设置网站图标原来我们在使用tomcat开发时,设置网站图片时,即icon图标时,一般都是直接替换root包下的favicon.ico替换成自己的,或者在网页的头部设置link的ref为icon然后设置其href值。而在SpringBoot中,替换图片也是很简单的,只需要将自定义图片放置在静态资源目录下即可,即默认有static、public、resources、/META-INF/resources或者自定义的静态目录下即可。目录结构:允许跨域访问CORS是一个W3C标准,全称是”跨域资源共享”(Cross-origin resource sharing)。它允许浏览器向跨源(协议+域名+端口)服务器,发出XMLHttpRequest请求,从而克服了AJAX只能同源使用的限制。简单来说,跨域问题是可以通过nginx来解决的,或者通过jsonp(只支持get请求)来解决。而SpringBoot中也提供了配置方法。0.利用@CrossOrigin注解,可放至在类上或者方法上。类上代表整个控制层所有的映射方法都支持跨域请求。CrossOrigin(origins="http://blog.lqdev.cn",maxAge=3600)@RestController public class demoController{GetMapper("/")public String index(){return"hello,CORS;} }1.配置全局CORS配置。官网也有给出实例,具体如下:Configuration public class MyConfiguration {Beanpublic WebMvcConfigurer corsConfigurer(){return new WebMvcConfigurerAdapter(){Overridepublic void addCorsMappings(CorsRegistry registry){ registry.addMapping("/api/*").allowedOrigins("https://blog.lqdev.cn");}};} }独立Tomcat运行讲解了这么久,一般上我们都是通过jar包的方式进行启动的应用的。所以部署在独立的tomcat时,需要如何解决呢?其实也简单,只需要将项目打包方式修改为war包,然后修改下启动类配置即可。0.修改pom打包方式为war,同时排除了内置的tomcat。war!排除内置的tomcat->org.springframework.bootspring-boot-starter-tomcatcompile若直接有使用servlet对象时(这是废话,⊙﹏⊙∣),需要将servlet引入,本例是没有的~->javax.servletjavax.servlet-apiprovided1.改造下启动类,使其继承SpringBootServletInitializer,同时覆盖configure方法。SpringBootApplication@Slf4j public class ChapterApplication extends SpringBootServletInitializer{public static void main(String[]args){SpringApplication.run(ChapterApplication.class,args);new SpringApplicationBuilder().sources(ChapterApplication.class).web(false).run(args);之后这里设置业务逻辑 比如挂起一个线程 或者设置一个定时任务。保证不退出不然它就是一个启动类,启动后就停止了。log.info("jar,chapter启动!}Overrideprotected SpringApplicationBuilder configure(SpringApplicationBuilder application){log.info("外部tomcat,chapter启动!return application.sources(ChapterApplication.class);} }2.maven打包成war(mvn clean install),然后放入tomcat中,启动运行即可。其实这样设置的话,在开发时直接运行启动类也还是可以直接运行的,方便.启动不设置端口对一些定时任务服务项目,其本身只是提供一个定时调度功能,不需要其他服务调用,只是去调度其他服务。像这样的服务,正常也就不需要设置端口了。这时候SpringBoot也是支持的。只需要改下启动方式:new SpringApplicationBuilder().sources(ChapterApplication.class).web(false).run(args);之后这里设置业务逻辑 比如挂起一个线程 或者设置一个定时任务。保证不退出不然它就是一个启动类,启动后就停止了。或者修改配置文件的属性:spring.main.web-environment=fals最后效果,是不是没有看见端口了:启动完成前进行业务逻辑利用CommandLineRunner或者..内容来自www.zgxue.com请勿采集。


  • 本文相关:
  • springboot集成redisson实现分布式锁的方法示例
  • spring boot整合redis的完整步骤
  • spring boot单元测试中使用mockito框架mock掉整个redistemplate的示例
  • 在springboot中添加redis及配置方法
  • python redis操作实例分析【连接、管道、发布和订阅等】
  • redis 订阅发布_jedis实现方法
  • nodejs redis 发布订阅机制封装实现方法及实例代码
  • redis数据类型_动力节点java学院整理
  • 如何操作redis和zookeeper实现分布式锁
  • redis服务器允许远程主机访问的方法
  • 使用redis实现延时任务的解决方案
  • redis中hash表内容删除的方法代码
  • 基于redis分布式锁的实现代码
  • redis分布式锁的问题与解决方法
  • redis配置文件代码讲解
  • redis的持久化方案详解
  • redis列表类型_动力节点java学院整理
  • idea 有没有spring boot插件
  • spring boot logback日志 怎么彩色输出
  • 用英语写一张明信片(6句给老师)
  • 电脑开机的时候出现Boot Menu 15[ 标签:电脑,boot,menu ] 开机的时候出现一个这样的英文框框 Boot Menu
  • 动荡的 Java 今年将有哪些新变化
  • GitHub上面有哪些经典的java框架源码
  • 26个字母在单词中的发音 发音表
  • 200个正确的英语名词
  • 世界50部经典电影都是哪些?
  • 岛津GC-14C气相色谱 分流比怎么设定
  • 网站首页网页制作脚本下载服务器操作系统网站运营平面设计媒体动画电脑基础硬件教程网络安全mssqlmysqlmariadboracledb2mssql2008mssql2005sqlitepostgresqlmongodbredisaccess数据库文摘数据库其它首页redisspringboot集成redisson实现分布式锁的方法示例spring boot整合redis的完整步骤spring boot单元测试中使用mockito框架mock掉整个redistemplate的示例在springboot中添加redis及配置方法python redis操作实例分析【连接、管道、发布和订阅等】redis 订阅发布_jedis实现方法nodejs redis 发布订阅机制封装实现方法及实例代码redis数据类型_动力节点java学院整理如何操作redis和zookeeper实现分布式锁redis服务器允许远程主机访问的方法使用redis实现延时任务的解决方案redis中hash表内容删除的方法代码基于redis分布式锁的实现代码redis分布式锁的问题与解决方法redis配置文件代码讲解redis的持久化方案详解redis列表类型_动力节点java学院整理超强、超详细redis数据库入门教程redis常用命令、常见错误、配置技redis操作命令总结redis中5种数据结构的使用场景介64位windows下安装redis教程redis中使用redis-dump导出、导入redis中统计各种数据大小的方法redis常用命令小结让redis在你的系统中发挥更大作用centos 6.6下redis安装配置记录redis sentinel实现哨兵模式搭建小结redis中scan命令的深入讲解redis发布订阅和实现.net客户端详解redis哈希和集合_动力节点java学院整理redis cluster集群数据分片机制原理redis中热key问题该如何解决redis服务器的启动过程分析redis单线程快的原因和原理详细分析redis集群故障redis瞬时高并发秒杀方案总结
    免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved