当前位置: 首页 > news >正文

成都网站建设招标丽水市建设局网站

成都网站建设招标,丽水市建设局网站,怎么知道这网站是php语言做的,微信小程序分销功能Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它可以基于 Spring Boot 来创建独立的、可用于生产的 Spring 应用程序。Spring Cloud Stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现#xff0c;并引入了发布-订阅、消费组、分区这三…        Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它可以基于 Spring Boot 来创建独立的、可用于生产的 Spring 应用程序。Spring Cloud Stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现并引入了发布-订阅、消费组、分区这三个核心概念。简单的说Spring Cloud Stream本质上就是整合了Spring Boot和Spring Integration实现了一套轻量级的消息驱动的微服务框架。 目前 Spring Cloud Stream只支持 RabbitMQ 和 Kafka 的自动化配置。 Spring Cloud Stream 提供了 Binder (负责与消息中间件进行交互)我们则通过 inputs 或者 outputs 这样的消息通道与 Binder 进行交互。Binder 绑定器是 Spring cloud Stream 中一个非常重要的概念实现了应用程序和消息中间件之间的隔离同时我们也可以通过应用程序实现消息中间件之间的通信。在我们的项目的可以继承多种绑定器我们可以根据不同特性的消息使用不同的消息中间件。Spring Cloud Stream 为我们实现了 RabbitMQ 和Kafka 的绑定器。如果你想使用其他的消息中间件需要自己去实现绑定器接口. 在 SpringCloudStream 3.x 版本前是通过 StreamListener 和 EnableBinding 进行消息的发送和消费的springCloudStream 3.x 版本后 StreamListener 和 EnableBinding 都打上了Deprecated 注解不建议使用了后续的版本更新中替换成函数式的方式实现。 既然通过四大函数式接口的方式替换了注解的方式 那么该如何进行绑定呢 通过 spring.cloud.stream.function.definition名称的方式进行绑定 公开 topic。 不管是创建 Consumer 还是 Supplier 或者是 Function Stream都会将其的 方法名称 进行 一个 topic拆封 和 绑定 假设 创建了一个 Consumer String myTopic 的方法Stream 会将其 拆分成 In 和 out 两个通道 输入 - -in- index 例如myTopic-in-0 输出 - -out- index 例如myTopic-out-0 注意这里的 functionName需要和代码声明的函数名称还有spring.cloud.stream.function.definition下的名称保持一致(后面还会在项目实战中展示一遍) 代码示例 ----------------------------------项目实战-------------------------------------- 看下我们项目中的配置配置文件是放在nacos上面的 消息发送 /*** ClassName MessageParamParentDto* Author zxd* Version 1.0.0* Description TODO* CreateTime 2023/6/13 11:27 - 星期二*/ Data public class MessageParamParentDto implements Serializable {private static final long serialVersionUID 7963819193258646924L;private String routeUrl;}-------------------------------------------------------------------------------------------------------------- /*** ClassName MessageParamDto* Author kch* Version 1.0.0* Description 消息队列接收系统消息实体对象* CreateTime 2022/9/18 15:16 - 星期日*/ Data public class MessageParamDto extends MessageParamParentDto implements Serializable {private static final long serialVersionUID 7111819193258646924L;/*** 消息模板code*/NotNull(message 消息模板不能为空)private String templateCode;/*** 可变参数,必传字段* 该参数匹配模板字符串中的变量和URL中的变量所以模板和URL中的变量名不能重复*/NotNull(message 参数不能为空)private MapString, String params;/*** 消息详情跳转路径参数没有不传有参数按照URL参数拼接规范拼接不加号* 例如userId1userCodetest*/ // private String routerParams;/*** 消息操作跳转路径参数没有不传有参数按照URL参数拼接规范拼接不加号* 例如userId1userCodetest*/ // private String contentPathParams;/*** 接收者租户*/NotNull(message 接收者租户ID不能为空)private Long tenantId;/*** 接收人*/NotNull(message 接收者用户ID不能为空)Size(min 1, message 接收者用户ID不能为空)private ListRecipientUser recipientUsers;ValidDataAllArgsConstructorNoArgsConstructorpublic static class RecipientUser implements Serializable {/*** 接收人id*/NotNull(message 接收者用户ID不能为空)private Long recipientId;/*** 接收人手机号*/Pattern(regexp RegexPool.MOBILE, message 手机格式错误)private String phone;}}----------------------------------------------------------------------------------------------------------- /*** ClassName MessageMqBinding* Author zpp* Version 1.0.0* Description TODO* CreateTime 2023/2/10 15:37 - 星期五*/ public interface MessageMqBinding {/*** 系统消息生产者交换机*/String MESSAGE_MQ_OUTPUT dyzsMessageProvider-out-0; }---------------------------------------------------------------------------------------- Slf4j RestController RequestMapping(/mq) public class MessageMqController {Resourceprivate StreamBridge streamBridge;/*** param :* Author zpp* Description 发送系统消息* Date 2023/2/10 15:27* Return com.zysy.common.api.entity.Resultjava.lang.Boolean*/PostMappingpublic ResultBoolean sendMessage(RequestBody Validated MessageParamDto dto) {log.info(接收到系统消息发送请求{}, JSONObject.toJSONString(dto));MessageMQParamDto paramDto new MessageMQParamDto(dto);paramDto.setCreateBy(UserUtil.getUserId());paramDto.setCreateDept(UserUtil.getDeptId());ListMessageMQParamDto paramDtoList new ArrayList();paramDtoList.add(paramDto);MessageBuilder builder MessageBuilder.withPayload(paramDtoList).setHeader(Content-Type, application/json);return Result.success(streamBridge.send(MessageMqBinding.MESSAGE_MQ_OUTPUT, builder.build()));} ------------------------------------------------------------------------------------------------------ 消息消费 下图是在代码中配置的消息消费者这里的函数名称要和上图中的function.definition配置的名称一样
http://www.sadfv.cn/news/347078/

相关文章:

  • 万网空间最多放几个网站做行业网站广告
  • 南京学习做网站中国建筑装修网
  • 深圳网站制作教程嘟嘟嘟在线观看播放免费
  • 东莞哪里做网站网页游戏传奇世界
  • 网站开发前端指什么著名的网站建设平台
  • 医院网站建设与维护题库建设银行官方网站企业网银
  • 黑龙江网站制作平台视频制作教程自学
  • qq官网登录入口手机版网站优化之站外优化技巧
  • 息烽做网站公司有哪些深圳市网络营销公司
  • 免费自助建设网站dw网页制作教程视频简单第二期
  • 如何建立一个网站来卖东西青海城乡与建设厅网站
  • python网站开发 django内容营销理论
  • 绵阳城乡住房建设厅网站太原网页设计最新招聘信息
  • 百度权重10的网站购物网站后台管理模板
  • 杭州建设信用网网站网站建设怎么宣传
  • 专业做网站建设 昆山网站建设行业的分析
  • 教学单位 网站建设天津网站大全
  • 营销型网站建设php源码百度权重域名
  • 河南省建设部省厅网站南京网站建设 零云建站
  • 桓台建设网站佛山网站建设技术托管
  • 凯里展示型网站设计wordpress参考文档
  • 做中国旅游网站的目的与必要性怎么把自己做的网站放到百度上
  • 宣传工作网站建设作用中国空间站机械臂
  • 哪里网站可以做微信头像制作网站软件教程
  • 定制网站公司哪家好seo优化排名易下拉软件
  • 建设工程资料下载网站一二年级的科技小制作
  • 萝岗区营销型网站建设学校网站建设价格
  • 视觉元素网站腾讯云服务器app
  • 花生壳内网穿透网站如何做seo优化建筑英才网官方
  • 电商网站开发环境静态手机网站建设的基本特点