RuleGo RuleGo
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文
🏠首页
  • 快速入门
  • 规则链
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 可视化
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • 触发器
  • 高级主题
  • 性能
  • 标准组件
  • 扩展组件
  • 自定义组件
  • 组件市场
  • 概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件
🔥编辑器 (opens new window)
  • 可视化编辑器 (opens new window)
  • RuleGo-Server (opens new window)
  • ❓问答

    • FAQ
💖支持
👥加入社区
  • Github (opens new window)
  • Gitee (opens new window)
  • GitCode (opens new window)
  • 更新日志 (opens new window)
  • English
  • 简体中文

广告采用随机轮播方式显示 ❤️成为赞助商
  • Endpoint概述
  • 快速入门
  • 路由
  • DSL
  • API
  • Options
  • 组件

    • Rest Endpoint
    • Websocket Endpoint
    • MQTT Endpoint
    • Schedule Endpoint
    • Net Endpoint
    • Kafka Endpoint
    • Nats Endpoint
    • Redis Sub Endpoint
    • Redis Steam Endpoint
    • Rabbitmq Endpoint
    • MYSQL CDC Endpoint
    • OPC_UA Endpoint
    • GRPC Stream Endpoint
    • Beanstalkd Endpoint
    • Wukongim Endpoint
    • 扩展Endpoint

扩展Endpoint

Endpoint模块 提供了一些内置的接收服务类型,但是你也可以自定义或扩展其他类型的接收服务。要实现这个功能,你需要遵循以下步骤:

  1. 实现Message接口 (opens new window) 。Message接口是一个用来抽象不同输入源数据的接口,它定义了一些方法来获取或设置消息的内容、头部、来源、参数、状态码等。你需要为你的接收服务类型实现这个接口,使得你的消息类型可以和endpoint包中的其他类型进行交互。
  2. 实现Endpoint接口 (opens new window) 。Endpoint接口是一个用来定义不同接收服务类型的接口,它定义了一些方法来启动、停止、添加路由和拦截器等。你需要为你的接收服务类型实现这个接口,使得你的服务类型可以和endpoint包中的其他类型进行交互。

以上就是扩展endpoint包的基本步骤,你可以参考已经有的endpoint类型实现来编写你自己的代码:

  • rest (opens new window)
  • websocket (opens new window)
  • mqtt (opens new window)
  • schedule (opens new window)
  • tcp/udp (opens new window)
  • Kafka (opens new window) (扩展组件库)
在 GitHub 上编辑此页 (opens new window)
上次更新: 2025/04/02, 01:29:50
Wukongim Endpoint

← Wukongim Endpoint

Theme by Vdoing | Copyright © 2023-2025 RuleGo Team | Apache 2.0 License

  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式