广州.NET培训
达内广州.NET培训中心

18589266248

热门课程

学程序员培训就业率好吗?KafKa线程是难学吗?

  • 时间:2017-08-08 17:47
  • 发布:博客园
  • 来源:博客园

flowCommond为要发送的对象内容,格式化为Json字符串再发送。一般在KafKa消费程序中消费可以设置多个主题,那在同一程序中需要向KafKa发送不同主题的消息,如异常需要发到异常主题,正常的发送到正常的主题,这时候就需要实例化多个主题,然后逐个发送。

达内培训】这里实现一个线程里面发送多个主题,那下面实现多个线程中如何发送多个主题。多线程中如果每个线程都newProducer(kfkip)一次,那KafKa的连接很快会被占满。那这里就用单例模式来解决这个问题,每次要用到Producer时检查一下是否已经存在Producer实例,若存在则直接用不用再生成。

1.原理

每一个线程对应一个消息队列MessageQueue,实现线程之间的通信,可通过Handler对象将数据装进Message中,再将消息加入消息队列,而后线程会依次处理消息队列中的消息。

2.Message

达内程序员培训】初始化:一般使用Message.obtain()方法获取一个消息对象,该方法会检查Message对象池中是否存在可重复利用的对象,若无,才会new一个新对象。

what:相当于Message的标识符,区别于其它消息。

arg1、arg2:int类型,可传递整数。

obj:object类型,可传递任意对象。

3.发送消息

在子线程中可调用主线程的handler.sendMessage(msg)进行发送消息,经过一系列方法调用,会触发handler的handleMessage方法,从而进行消息处理。

学编程技术,您可以咨询广州达内,这是个不错的选择!

扫码加入超值试听报名!

广州达内

上一篇:达内程序员培训: 荣耀千元机外观设计可圈可点
下一篇:零基础能学Net培训那?请看定义TagHelpers技术

广州.Net培训:.Net培训有什么特色?

广州.Net培训:学习.Net的几个基本步骤

达内海归硕士高薪入职软通动力外派华为

女生适合做程序员吗?美女程序员用技术征服IT名企

选择城市和中心
贵州省

广西省

海南省