golang：订阅模式

ゝ一纸荒年。 2022-02-19 00:29 228阅读 0赞

package main
    
    import (
    	"fmt"
    )
    
    type Channel struct {
        
    	userName string
    }
    
    type Channels struct {
        
    	chann map[string]map[string]Channel
    }
    
    //注册订阅者
    func (ch *Channels) Reg(appId string,userId string,userName string)  {
        
    	c := new(Channel)
    	c.userName = userName
    	if ch.chann == nil {
        
    		ch.chann = make(map[string]map[string]Channel)
    	}
    	if ch.chann[appId] == nil {
        
    		ch.chann[appId] = make(map[string]Channel)
    	}
    
    	ch.chann[appId][userId] = *c
    }
    //取消订阅
    func (ch *Channels) Remove(appId string,userId string)  {
        
    	if ch.chann[appId] == nil {
        
    		fmt.Println("该通道不存在")
    	}else {
        
    		delete(ch.chann[appId],userId)
    	}
    }
    //发送消息
    func (ch *Channels) Send(appId string,msg string)  {
        
    	for k,v := range ch.chann[appId] {
        
    		fmt.Println(appId,k,v.userName,msg)
    	}
    }
    
    
    func main1(){
        
    	c := new(Channels)
    	c.Reg("1", "1", "小红")
    	c.Reg("1", "2", "小明")
    	c.Reg("2", "2", "小李")
    	c.Send("1", "你好")
    	c.Remove("1", "1")
    	c.Send("1", "你好")
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，228人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ 订阅模式

一、订阅模式官方内容参考：[http://www.rabbitmq.com/tutorials/tutorial-three-java.html][http_www.r

ゝ一世哀愁。/ 2024年03月25日 20:16/ 0 赞/ 126 阅读

相关 RabbitMQ：订阅模型-消息订阅模式

> 订阅模型-消息订阅模式，也可以称为广播模式，生产者将消息发送到 Exchange，Exchange 再转发到与之绑定的 Queue中，每个消费者再到自己的 Queue 中取

淡淡的烟草味﹌/ 2023年09月23日 20:12/ 0 赞/ 67 阅读

相关 RocketMQ--订阅模式

> 创建者 public class OrderedProducer { public static void main(String[] args)

不念不忘少年蓝@/ 2023年06月11日 13:21/ 0 赞/ 13 阅读

相关 redis发布/订阅模式

大家都知道Redis中的list结构可以作为队列来满足一些生产消费的业务场景。实际上Redis还提供了发布/订阅（publish/subscribe）模式来实现类似的生产消费的

秒速五厘米/ 2022年10月16日 09:38/ 0 赞/ 217 阅读

相关 golang并发-发布订阅并发模型

文章目录简介发布订阅模型简介发布订阅模型简写为 pub/sub 模型，消息生产者成为了发布者 publisher，消息消费者成为了订阅者 su

￡神魔★判官ぃ/ 2022年09月17日 03:03/ 0 赞/ 174 阅读

相关 208.卡片订阅模式

效果 (源码网盘地址在最后) ![45d7d422deb321b55ca7b950a7e6b480.gif][] 源码 index.html <!DOC

淩亂°似流年/ 2022年09月07日 05:59/ 0 赞/ 133 阅读

相关 rabbitmq(5)订阅模式

1、模型一个生产者绑定一个交换机，每个消费者绑定一个队列。生产者将消息通过交换器分发给所有在线的消费者。交换机没有消息存储的能力，只能向当前在线的消费者发送消息。

逃离我推掉我的手/ 2022年05月29日 14:07/ 0 赞/ 217 阅读

相关 RabbitMQ（四）：订阅模式

一、订阅模式官方内容参考：[http://www.rabbitmq.com/tutorials/tutorial-three-java.html][http_www.r

港控/mmm°/ 2022年05月23日 04:18/ 0 赞/ 292 阅读

相关 golang：订阅模式

package main import ( "fmt" ) type Channel struct {

ゝ一纸荒年。/ 2022年02月19日 00:29/ 0 赞/ 229 阅读

相关 Golang redis(六)redigo 发布订阅模式

发布订阅使用Send，Flush和Receive方法实现Pub / Sub c.Send("SUBSCRIBE", "example") c.Flus

我不是女神ヾ/ 2021年12月09日 22:41/ 0 赞/ 618 阅读