TOPIC精品文章

• 

  深度解析RocketMQ Topic的創(chuàng)建機(jī)制

  ...還記得第一次使用rocketmq的時(shí)候，需要去控制臺(tái)預(yù)先創(chuàng)建topic，我當(dāng)時(shí)就想為什么要這么設(shè)計(jì)，于是我決定擼一波源碼，帶大家從根源上吃透rocketmq topic的創(chuàng)建機(jī)制。 topic在rocketmq的設(shè)計(jì)思想里，是作為同一個(gè)業(yè)務(wù)邏輯消息的組織...

  gself 2019-08-16 16:17 評(píng)論0 收藏0
• 

  python3連接kafka模塊pykafka生產(chǎn)者簡(jiǎn)單封裝

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

  fizz 2019-07-31 10:29 評(píng)論0 收藏0
• 

  Scrapy 抓取知乎的問(wèn)題

  ... 對(duì)于每個(gè)問(wèn)題抓取 標(biāo)題，關(guān)注人數(shù)，回答數(shù)等數(shù)據(jù) 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 評(píng)論0 收藏0
• 

  rocketmq之producer解析

  ...名，相同分組的producer應(yīng)該有相同的發(fā)送消息邏輯 createTopicKey AUTO_CREATE_TOPIC_KEY 自動(dòng)創(chuàng)建topic時(shí)，以此默認(rèn)topic為模板創(chuàng)建指定topic defaultTopicQueueNums 4 自動(dòng)創(chuàng)建topic隊(duì)列數(shù)量 sendMsgTimeout 3000 發(fā)送消息的超時(shí)時(shí)間，單位ms compressM...

  luodongseu 2019-08-19 11:15 評(píng)論0 收藏0
• 

  Python學(xué)習(xí)之路18-用戶賬戶

  ...承Django的ModelForm類： from django import forms from .models import Topic class TopicForm(forms.ModelForm): class Meta: model = Topic fields = [text] labels = {text: } 最簡(jiǎn)單...

  bovenson 2019-07-31 11:09 評(píng)論0 收藏0
• 

  設(shè)計(jì)一個(gè)基于svg的涂鴉組件（一）

  ...應(yīng)的通信能力： 組件聲明為訂閱者（Subscriber）并通過(guò)@Topics注解的形式從消息中心訂閱自己感興趣的主題消息，對(duì)應(yīng)的消息會(huì)通過(guò)notify接口告知組件； 組件聲明為發(fā)布者（Publisher），可以通過(guò)Publisher角色注入的publish方法發(fā)...

  cartoon 2019-08-22 17:13 評(píng)論0 收藏0
• 

  AmplifyJS源碼簡(jiǎn)析：事件分發(fā)

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

  騫諱護(hù) 2019-08-21 10:26 評(píng)論0 收藏0