TOPIC

TOPIC精品文章

• 

  深度解析RocketMQ Topic的创建机制

  ...还记得第一次使用rocketmq的时候，需要去控制台预先创建topic，我当时就想为什么要这么设计，于是我决定撸一波源码，带大家从根源上吃透rocketmq topic的创建机制。 topic在rocketmq的设计思想里，是作为同一个业务逻辑消息的组织...

  gself 2019-08-16 16:17 评论0 收藏0
• 

  python3连接kafka模块pykafka生产者简单封装

  ...IP:9092, IP:9092 client = KafkaClient(hosts = host) # 生产者 topicdocu = client.topics[my-topic] producer = topicdocu.get_producer() for i in range(100): print i prod...

  fizz 2019-07-31 10:29 评论0 收藏0
• 

  Scrapy 抓取知乎的问题

  ... 对于每个问题抓取 标题，关注人数，回答数等数据 zhihuTopicSpider.py # -*- coding: utf-8 -*- import scrapy import os import time import re import json from ..items import zhihuQuestionItem # mode 1:tencent 2:free mo...

  xiao7cn 2019-07-24 18:26 评论0 收藏0
• 

  rocketmq之producer解析

  ...名，相同分组的producer应该有相同的发送消息逻辑 createTopicKey AUTO_CREATE_TOPIC_KEY 自动创建topic时，以此默认topic为模板创建指定topic defaultTopicQueueNums 4 自动创建topic队列数量 sendMsgTimeout 3000 发送消息的超时时间，单位ms compressM...

  luodongseu 2019-08-19 11:15 评论0 收藏0
• 

  Python学习之路18-用户账户

  ...承Django的ModelForm类： from django import forms from .models import Topic class TopicForm(forms.ModelForm): class Meta: model = Topic fields = [text] labels = {text: } 最简单...

  bovenson 2019-07-31 11:09 评论0 收藏0
• 

  设计一个基于svg的涂鸦组件（一）

  ...应的通信能力： 组件声明为订阅者（Subscriber）并通过@Topics注解的形式从消息中心订阅自己感兴趣的主题消息，对应的消息会通过notify接口告知组件； 组件声明为发布者（Publisher），可以通过Publisher角色注入的publish方法发...

  cartoon 2019-08-22 17:13 评论0 收藏0
• 

  AmplifyJS源码简析：事件分发

  ...bscriptions = {}; var amplify = global.amplify = { publish: function( topic ) { // ... }, subscribe: function( topic, context, callback, priority ) { // ... }, ...

  骞讳护 2019-08-21 10:26 评论0 收藏0