golang：订阅模式

ゝ一纸荒年。 2022-02-19 00:29 185阅读 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 条评论，185人围观）

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

相关阅读

相关 RabbitMQ 订阅模式

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

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

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

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

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

相关 redis发布/订阅模式

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

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

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

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

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

相关发布订阅设计模式

> 发布订阅设计模式在程序中经常涉及，例如 Vue 中的 `$on` 和 `$off`、`document.addEventListener()`、`document.remo

Love The Way You Lie/ 2022年09月03日 13:22/ 0 赞/ 191 阅读

相关 rabbitmq(5)订阅模式

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

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

相关 RabbitMQ（四）：订阅模式

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

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

相关 RabbitMQ订阅者模式

订阅者模式一个生产者，多个消费者每一个消费者，都有一个独立的队列生产者没有将消息直接发送到队列，而是发送到了交换机每个队列都要绑定到交换机生产者发

ゝ一纸荒年。/ 2022年05月16日 04:39/ 0 赞/ 210 阅读

相关 golang：订阅模式

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

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

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

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

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