快上网专注成都网站设计 成都网站制作 成都网站建设
成都网站建设公司服务热线:028-86922220

网站建设知识

十年网站开发经验 + 多家企业客户 + 靠谱的建站团队

量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决

如何实现Storm-kafka

这篇文章将为大家详细讲解有关如何实现Storm-kafka,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

10年的合水网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。成都营销网站建设的优势是能够根据用户设备显示端的尺寸不同,自动调整合水建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。创新互联从事“合水网站设计”,“合水网站推广”以来,每个客户项目都认真落实执行。

         实现细节如下:

public static Iterable> generateTuples(
			KafkaConfig kafkaConfig, Message msg) {

		Iterable> tups;

		ByteBuffer payload = msg.payload();
		ByteBuffer key = msg.key();

		if (key != null
				&& kafkaConfig.scheme instanceof KeyValueSchemeAsMultiScheme) {
			tups = ((KeyValueSchemeAsMultiScheme) kafkaConfig.scheme)
					.deserializeKeyAndValue(Utils.toByteArray(key),
							Utils.toByteArray(payload));
		} else {
			tups = kafkaConfig.scheme.deserialize(Utils.toByteArray(payload));
		}
		return tups;
	}

  

      1   :方法内部 Iterable> 类型的tups对象

      2   :  Message对象是kafka的Message。 包括了Key,以及palyload负载

      3    :   在生成元组的时候,需要拿到kafkaConfig.scheme 当中的Scheme,一旦Scheme instanceof

                KeyValueSchemeAsMultiScheme,将强制性转换为 KeyValueSchemeAsMultiScheme,并且调用deserializeKeyAndValue 方法将其反序列化 List

     细节上,让我们查看一下  KeyValueSchemeAsMultiScheme 对象

package com.mixbox.storm.kafka;

import backtype.storm.spout.SchemeAsMultiScheme;
import java.util.Arrays;
import java.util.List;

@SuppressWarnings("serial")
public class KeyValueSchemeAsMultiScheme extends SchemeAsMultiScheme{

    public KeyValueSchemeAsMultiScheme(KeyValueScheme scheme) {
        super(scheme);
    }

    
    //把一个key value 进行反序列化
    public Iterable> deserializeKeyAndValue(final byte[] key, final byte[] value) {
    	
        List o = ((KeyValueScheme)scheme).deserializeKeyAndValue(key, value);
        
        if(o == null) return null;
        
        else return Arrays.asList(o);
    }
}

           首先, KeyValueSchemeAsMultiScheme 继承自SchemeAsMultiScheme,SchemeAsMultiScheme是Storm自身所带有的一个class实现,以上的2个class 都实现了Storm之中【MultiScheme】

关于“如何实现Storm-kafka”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。


本文标题:如何实现Storm-kafka
文章网址:http://6mz.cn/article/gdoepe.html

免费获取网站建设与品牌策划方案报价

*主要业务范围包括:高端网站建设, 集团网站建设(网站建设网站制作)找网站建设公司就上快上网。
提交需求

    联系我们

    028-86922220
  • 手机:13518219792
  • 地址:成都市太升南路288号锦天国际A幢1002号
  • 24小时服务热线:400-028-6601

    网站建设服务

  • 网页设计
  • 网站制作
  • 网站开发

    网站推广服务

  • 营销网站建设
  • 百度快速排名
  • 整站网站推广

    网站运维服务

  • 基础维护
  • 网站改版
  • 网站维护

    FOLLOW US

  • 微信二维码

    微信二维码

Copyright © 2022 成都快上网科技有限公司 成都网站建设公司-选网站建设公司快上网!国内专业的网站制作公司!
All Rights Reserved 版权所有 蜀ICP备19037934号-11