当前位置: 首页 > news >正文

建设银行企业网站wordpress 相互关注

建设银行企业网站,wordpress 相互关注,建筑英才网app,体育新闻最新消息这里是weihubeats,觉得文章不错可以关注公众号小奏技术#xff0c;文章首发。拒绝营销号#xff0c;拒绝标题党 RocketMQ版本 5.1.0 背景 我们都知道RocketMQ 5.x新增了proxy模式部署方式#xff0c;也就是支持了GRPC的消费方式消费#xff0c;所以今天我们来试试 本次… 这里是weihubeats,觉得文章不错可以关注公众号小奏技术文章首发。拒绝营销号拒绝标题党 RocketMQ版本 5.1.0 背景 我们都知道RocketMQ 5.x新增了proxy模式部署方式也就是支持了GRPC的消费方式消费所以今天我们来试试 本次使用的开发语言是goland 前置条件 这里默认我们已经部署了RocketMQ proxy,如果不会部署的可以参考我之前的文章 依赖管理 本次使用的依赖管理方式是go.mod 使用的goland sdk是github.com/apache/rocketmq-clients/golang 也就是这个开源项目 我们直接执行 go get github.com/apache/rocketmq-clients/golangmaster以master分支作为我们的依赖 发送消息 package mainimport (contextfmtlogosstrconvtimermq_client github.com/apache/rocketmq-clients/golanggithub.com/apache/rocketmq-clients/golang/credentials )const (Topic xiao-zou-topicEndpoint 127.0.0.1:8081AccessKey xxxxxxSecretKey xxxxxx )func main() {os.Setenv(mq.consoleAppender.enabled, true)rmq_client.ResetLogger()// new producer instanceproducer, err : rmq_client.NewProducer(rmq_client.Config{Endpoint: Endpoint,Credentials: credentials.SessionCredentials{AccessKey: AccessKey,AccessSecret: SecretKey,},},rmq_client.WithTopics(Topic),)if err ! nil {log.Fatal(err)}// start producererr producer.Start()if err ! nil {log.Fatal(err)}// graceful stop producerdefer producer.GracefulStop()for i : 0; i 10; i {// new a messagemsg : rmq_client.Message{Topic: Topic,Body: []byte(this is a message : strconv.Itoa(i)),}// set keys and tagmsg.SetKeys(a, b)msg.SetTag(ab)// send message in syncresp, err : producer.Send(context.TODO(), msg)if err ! nil {log.Fatal(err)}for i : 0; i len(resp); i {fmt.Printf(%#v\n, resp[i])}// wait a momenttime.Sleep(time.Second * 1)} }我们可以直接运行,然后看到消息发送成功了 消息消费 package mainimport (contextfmtlogostimermq_client github.com/apache/rocketmq-clients/golanggithub.com/apache/rocketmq-clients/golang/credentials )const (Topic xiao-zou-topicConsumerGroup gid-xiaozou-grpcEndpoint 127.0.0.1:8081AccessKey xxxxxxSecretKey xxxxxx )var (// maximum waiting time for receive funcawaitDuration time.Second * 5// maximum number of messages received at one timemaxMessageNum int32 16// invisibleDuration should 20sinvisibleDuration time.Second * 20// receive messages in a loop )func main() {// log to consoleos.Setenv(mq.consoleAppender.enabled, true)rmq_client.ResetLogger()// new simpleConsumer instancesimpleConsumer, err : rmq_client.NewSimpleConsumer(rmq_client.Config{Endpoint: Endpoint,ConsumerGroup: ConsumerGroup,Credentials: credentials.SessionCredentials{AccessKey: AccessKey,AccessSecret: SecretKey,},},rmq_client.WithAwaitDuration(awaitDuration),rmq_client.WithSubscriptionExpressions(map[string]*rmq_client.FilterExpression{Topic: rmq_client.SUB_ALL,}),)if err ! nil {log.Fatal(err)}// start simpleConsumererr simpleConsumer.Start()if err ! nil {log.Fatal(err)}// graceful stop simpleConsumerdefer simpleConsumer.GracefulStop()go func() {for {fmt.Println(start receive message)mvs, err : simpleConsumer.Receive(context.TODO(), maxMessageNum, invisibleDuration)if err ! nil {fmt.Println(err)}// ack messagefor _, mv : range mvs {simpleConsumer.Ack(context.TODO(), mv)msg : string(mv.GetBody())fmt.Println(msg)}fmt.Println(wait a moment)fmt.Println()time.Sleep(time.Second * 3)}}()select {} }执行结果: 源码 相关源码已上传到github需要可以自取 https://github.com/weihubeats/java-to-go-learning/tree/main/student/rocketmq-demo 总结 可以看到我们使用GRPC的方式消费和发送消息都成功了但是需要注意的是目前rocketmq-clients还不是很稳定有一些bug生产使用还是需要谨慎
http://wiki.neutronadmin.com/news/257657/

相关文章:

  • 如何做网站充值三把火科技网站设计
  • 网站开发费用科目开网站做代销好
  • 沈阳建站费用手机网站dedecms
  • 萍乡做网站的公司有哪些未来做哪些网站致富
  • 杭州做公司网站网站的分类有哪些类型
  • 化妆品网站 源码wordpress伪静态格式
  • 美食网站建设设计方案百度地图收录提交入口
  • 学校门户网站建设工作网络推广方案写作七步法
  • 十大ppt模板免费下载网站视频网站搭建源码
  • 合肥网站建设博客微信小程序注册登录
  • 河南网站推广优化报价东莞高端网站设计
  • 门户网站制作全包网站开发能封装成app吗
  • 网站建设用哪种语言公司网站非响应式模板
  • 潍坊网站建设案例亚马逊购物网站
  • 网站上传空间wordpress 关闭头像
  • 做网站卖袜子效益如何富阳网站建设服务
  • 湖南+网站建设一键网站制作app
  • 温州网站制作计划wordpress电话
  • 佛山外贸网站新乡百度网站推广工具
  • 惠州网站建设行业园林专业设计学习网站
  • 建自己的网站百度指数是啥
  • 小说阅读网站开发视频肇庆企业自助建站
  • 全国卫生机构建设管理系统网站手机应用开发工具
  • 免费公文写作网站网络销售推广平台
  • 备案名称和网站logo不一致网站建设制作设计营销公司四川
  • 网站seo关键词优化排名wordpress米表域名展
  • 黄岩做网站的公司注册网站入口
  • 网站建设公司现在还挣钱吗做网站论文
  • 医院网站怎么做wordpress图片灯箱
  • 做百度网站要注意什么抛丸机网站怎么做