开课中国  |  [Investor Relations]   |  官方微博

广州.NET培训中心

美国上市公司 · 亿元级外企.NET培训企业

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

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

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

  • 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技术

2001-2016 达内时代科技集团有限公司 版权所有 京ICP证8000853号-56