首页技术区最新随笔(rss) RSS

搜索  注册  仅列出标题  新闻风格  

SPRING CLOUD - REACTIVE FEIGN

     摘要: 目前SPRING CLOUD(2020)尚未支持REACTIVE FEIGN，但官方推荐使用feign-reactive。pom.xmlCode highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/--><dependency>  &nbs...  阅读全文

2021-12-01 16:45 作者: paulwong【评论:0】【阅读:52】 

长连接网关技术专题(六)：石墨文档单机50万WebSocket长连接架构实践

     摘要: 本文由石墨文档技术杜旻翔分享，原题“石墨文档 Websocket 百万长连接技术实践”，有修订。1、引言在石墨文档的部分业务中，例如文档分享、评论、幻灯片演示和文档表格跟随等场景，涉及到多客户端数据实时同步和服务端批量数据在线推送的需求，一般的 HTTP 协议无法满足服务端主动 Push 数据的场景，因此选择采用 WebSocket 方案进行业务开发。随着石墨文档业务发展，...  阅读全文

2021-12-01 12:55 作者: Jack Jiang【评论:0】【阅读:56】 

基于实践：一套百万消息量小规模IM系统技术要点总结

     摘要: 本文由公众号“后台技术汇”分享，原题“基于实践，设计一个百万级别的高可用 & 高可靠的 IM 消息系统”，原文链接在文末。由于原文存在较多错误和不准确内容，有大量修订和改动。1、引言大家好，我是公众号“后台技术汇”的博主“一枚少年”。本人从事后台开发工作 3 年有余了，其中让我感触最深刻的一个项...  阅读全文

2021-11-27 13:00 作者: Jack Jiang【评论:0】【阅读:80】 

SPRING REACTOR 之Flux和Mono

SPRING REACTOR 之Flux和Mono，有点象SPRING INTEGRATION的IntegrationFlow，有如下特点
  • 定义了针对某种类型数据的处理流程
  • 可以进行类型转换
  • 长期运行，除非被要求中止
  • 流程中的每种操作可以在新的线程中执行
  • 可以正常中止，如果中途有异常，则该流程也会中止
  • 要subscribe，流程才开始被启动
  • 可以分割成各个子流程
  • 可以聚合子流程
  • Mono发送一个数据，就发送中止信号
  • Flux发送任意数据，由程序决定何时发送中止信号

编程则比较简单，先根据不同的数据类型定义不同的Flux或Mono，业务操作用Function包装后，放在map/flatmap中，再调用subscribe启动流程。

2021-11-23 14:30 作者: paulwong【评论:0】【阅读:81】 

SPRING REACTOR 使用样例

     摘要: SpringReactorTest.javaCode highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/-->package com.paul.testreactivestream.reactor;import java.util.List;impo...  阅读全文

2021-11-23 13:59 作者: paulwong【评论:0】【阅读:68】 

EVEN DRIVEN - SPRING CLOUD STREAM - 从非SCS组件发送消息到SCS组件

     摘要: 在SPRING INTEGRATION中，如果要从非SPRING INTEGRATION代码发送MESSAGE到SPRING INTEGRATION程序，通常用BUS GATEWAY。 那么在SPRING CLOUD STREAM中，如果要从非SPRING CLOUD STREAM代码发送MESSAGE到SPRING CLOUD STREAM程序，通常就要先通知框架自动生成一个SOURCE。...  阅读全文

2021-11-19 11:47 作者: paulwong【评论:0】【阅读:84】 

阿里IM技术分享(六)：闲鱼亿级IM消息系统的离线推送到达率优化

     摘要: 本文由阿里闲鱼技术团队逸昂分享，原题“消息链路优化之弱感知链路优化”，有修订和改动，感谢作者的分享。1、引言闲鱼的IM消息系统作为买家与卖家的沟通工具，增进理解、促进信任，对闲鱼的商品成交有重要的价值，是提升用户体验最关键的环节。然而，随着业务体量的快速增长，当前这套消息系统正面临着诸多急待解决的问题。以下几个问题典型最为典型：1）在线消息的体验提升；2）离线推送的到达率；...  阅读全文

2021-11-17 12:24 作者: Jack Jiang【评论:0】【阅读:82】 

EVEN DRIVEN - SPRING CLOUD STREAM - Error Handling

     摘要: 如果Function中抛出异常，系统没有配置捕获异常，则异常消息会被丢弃。通常会进行配置。Code highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/-->@ServiceActivator(inputChannel = "my-destinatio...  阅读全文

2021-11-17 10:50 作者: paulwong【评论:0】【阅读:70】 

EVEN DRIVEN - SPRING CLOUD STREAM - Function Component

如果要在SPRING CLOUD STREAM中和其他中间件打交道，如FILE、FTP、HTTP等，则要用到SPRING CLOUD FUNCTION。

组件地址：
https://github.com/spring-cloud/stream-applications/tree/main/functions

特殊组件，将FUNCTION变成HTTP ENDPOINTS：
https://github.com/spring-cloud/spring-cloud-function/tree/main/spring-cloud-starter-function-web
https://github.com/spring-cloud/spring-cloud-function/tree/main/spring-cloud-starter-function-webflux

2021-11-15 17:40 作者: paulwong【评论:0】【阅读:70】 

EVEN DRIVEN - SPRING CLOUD STREAM - Routing Function

     摘要: SPRING CLOUD STREAM内置了一个RoutingFunction，能将MESSAGE路由到应用的其他FUNCTION中。对接RoutingFunction可发送消息到其外部DESTINATION中或用“｜”连接符连接。application.yamlCode highlighting produced by Actipro CodeHighlighter (f...  阅读全文

2021-11-15 14:46 作者: paulwong【评论:0】【阅读:75】 

IM开发基础知识补课(十)：大型IM系统有多难？万字长文，搞懂异地多活！

     摘要: 本文由公众号“水滴与银弹”号主Kaito原创分享，原题“搞懂异地多活，看这篇就够了”，为使文章更好理解，即时通讯网收录时有修订。1、引言前几天技术群里有群友问我52im社区里有没有IM分布式系统异地多活方面的文章，我仔细想了想，除了微信分享的几篇文章里有提到容灾和异地多活（只是大致提过，没有详细展开），确实目前还没有系统性的异地多活技术资料可供参考。...  阅读全文

2021-11-10 15:18 作者: Jack Jiang【评论:0】【阅读:78】 

EVEN DRIVEN - SPRING CLOUD STREAM 3.x - Functional Programming Model

     摘要: SPRING CLOUD STREAM 3.x 版本时，之前的一些编程模式，如@Enablebindding，@StreamListenner等注释被废弃了，这是由于一些框架的代码必需由用户编写，如配置框架用的Input MessageChannel，Output  MessageChannel，连接MessageHandler与MessageChannel等，被视为不必要的动...  阅读全文

2021-11-10 15:10 作者: paulwong【评论:0】【阅读:88】 

在CENTOS LINUX上安装RABBITMQ

     摘要: 安装ERLANG从这里下载0依赖的ERLANG安装包：https://github.com/rabbitmq/erlang-rpm/releases 象这种erlang-23.3.4.8-1.el7.x86_64.rpm含el7的是CENTOS7版本，含el8的是CENTOS8版本，安装脚本Code highlighting produced by Actipro CodeHighlig...  阅读全文

2021-11-08 09:27 作者: paulwong【评论:0】【阅读:82】 

EVEN DRIVEN - SPRING CLOUD STREAM - SPRING CLOUD微服务的EVEN DRIVEN框架

     摘要: 通常微服务应用之间的通信是通过HTTP调用，吞吐性不建都高，高并发的场景建议使用EVENT DRIVEN的框架，即使用MESSAGE通信。即A微服务应用将数据发送到MESSAGE BROKER中的某个DESTINATION，此DESTINATION是广播型，非点对点型。B微服务应用订阅此DESTINATION，当有新MESSAGE到达此DESTINATION时，MESSAGE BROKER会将此M...  阅读全文

2021-11-05 14:58 作者: paulwong【评论:0】【阅读:71】 

技 术 改 变 世 界

宣传语

网站分类

其他分类

Google站内搜索

 

24小时内最热随笔

统计信息

订阅

Blog客户端API

推荐客户端

博客排行榜[前100人]