PubSub

• Producers send messages to specific brokers rather than directly to consumers.
• Brokers cache messages sent by producers and then actively push them to subscribed consumers or pull them.

The system architectures use this pattern to decouple or handle high traffic scenarios.

Apache APISIX implement an extensible pubsub module, which is responsible for starting the WebSocket server, coding and decoding communication protocols, handling client commands, and adding support for the new messaging system.

• Add a new option to the configuration item in upstream
• Add a new judgment branch to
• Implement the required message system instruction processing functions
• Optional: Create plugins to support advanced configurations of this messaging system

Example