搜索[twitter]结果-低调大师优秀个人博客

精选列表

搜索[twitter]，共2535篇文章

Twitter现在允许用户通过"私信"录制并传送视频

社交网站Twitter今日宣布推出一项全新功能，允许用户可以通过“私信(direct messages)”直接录制并传送视频。

2017-07-02

Twitter 开源了数据实时分析平台 Heron

去年，Twitter对外宣布了新的分布式流计算系统Heron，随后消息称Twitter已经用Heron替换了Storm。

2017-06-01

s4和Twitter storm的粗略比较

s4 Twitter Storm 协议 Apache license 2.0 Eclipse Public License 1.0 开发语言 Java Clojure,Java,Clojure编写了核心代码

2017-05-01

阿里、Google、Twitter面向容器的资源调度技术比较

Mesos Twitter研发的超级网络系统，Mesos的出现比YARN早,引入两级调度的理念。两级调度通过一个名为资源邀约的新API发起，邀约是有时间限制的，激励应用程序去实现快速地调度。

2017-05-01

Bolt作为task被executor执行，而executor是一个个的线程，所以executor必须存在于具体的process之中，而这个process就是worker。至于worker是如何被supervisor创建，尔后worker又如何创建executor线程，这些暂且按下不表。假设同属于一个Topology的Spout与Bolt分别处于不同的JVM，即不同的worker中，不同的JVM可能处于同一台物理机器，也可能处于不同的物理机器中。为了让情景简单，认为JVM处于不同的物理机器中。 Spout的输出消息到达Bolt，作为Bolt的输入会经过这么几个阶段。 1. spout的输出通过该spout所处worker的消息输出线程，将tuple输入到Bolt所属的worker。它们之间的通路是socket连接，用ZeroMQ实现。 2. bolt所处的worker有一个专门处理socket消息的receive thread 接收到spout发送来的tuple 3. receive thread将接收到的消息传送给对应的bolt所在的executor。在worker内部（即同一process内部),消息传递使用的是Lmax Disruptor pattern. 4. executor接收到tuple之后，由event-handler进行处理下面是具体的源码 1. worker创建消息接收线程 worker.clj (defn launch-receive-thread [worker] (log-message "Launching receive-thread for " (:assignment-id worker) ":" (:port worker)) (msg-loader/launch-receive-thread! (:mq-context worker) (:storm-id worker) (:port worker) (:transfer-local-fn worker) (-> worker :storm-conf (get TOPOLOGY-RECEIVER-BUFFER-SIZE)) :kill-fn (fn [t] (halt-process! 11)))) 注意加亮的行会将storm.yaml中配置使用ZMQ或其它 storm.messaging.transport:"backtype.storm.messaging.zmq" 2. worker从socket接收到新消息 vthread (async-loop (fn [] (let [socket (.bind ^IContext context storm-id port)] (fn [] (let [batched (ArrayList.) init (.recv ^IConnection socket 0)] (loop [packet init] (let [task (if packet (.task ^TaskMessage packet)) message (if packet (.message ^TaskMessage packet))] (if (= task -1) (do (log-message "Receiving-thread:[" storm-id ", " port "] received shutdown notice") (.close socket) nil ) (do (when packet (.add batched [task message])) (if (and packet (< (.size batched) max-buffer-size)) (recur (.recv ^IConnection socket 1)) (do (transfer-local-fn batched) 0 )))))))))) 加亮行使用的transfer-local-fn会将接收的TaskMessage传递给相应的executor 3. transfer-local-fn (defn mk-transfer-local-fn [worker] (let [short-executor-receive-queue-map (:short-executor-receive-queue-map worker) task->short-executor (:task->short-executor worker) task-getter (comp #(get task->short-executor %) fast-first)] (fn [tuple-batch] (let [grouped (fast-group-by task-getter tuple-batch)] (fast-map-iter [[short-executor pairs] grouped] (let [q (short-executor-receive-queue-map short-executor)] (if q (disruptor/publish q pairs) (log-warn "Received invalid messages for unknown tasks. Dropping... ") ))))))) 用disruptor在线程之间进行消息传递。多费一句话，mk-transfer-local-fn表示将外部世界的消息传递给本进程内的线程。而mk-transfer-fn则刚好在方向上反过来。 4. 消息被executor处理 executor.clj ========================================================== (defn mk-task-receiver [executor-data tuple-action-fn] (let [^KryoTupleDeserializer deserializer (:deserializer executor-data) task-ids (:task-ids executor-data) debug? (= true (-> executor-data :storm-conf (get TOPOLOGY-DEBUG))) ] (disruptor/clojure-handler (fn [tuple-batch sequence-id end-of-batch?] (fast-list-iter [[task-id msg] tuple-batch] (let [^TupleImpl tuple (if (instance? Tuple msg) msg (.deserialize deserializer msg))] (when debug? (log-message "Processing received message " tuple)) (if task-id (tuple-action-fn task-id tuple) ;; null task ids are broadcast tuples (fast-list-iter [task-id task-ids] (tuple-action-fn task-id tuple) )) )))))) 加亮行中tuple-action-fn定义于mk-threads(源文件executor.clj)中。因为当前以Bolt为例，所以会调用的tuple-action-fn定义于 defmethod mk-threads :bolt [executor-data task-datas] 那么mk-task-receiver是如何与disruptor关联起来的呢，可以见定义于mk-threads中的下述代码 (let [receive-queue (:receive-queue executor-data) event-handler (mk-task-receiver executor-data tuple-action-fn)] (disruptor/consumer-started! receive-queue) (fn [] (disruptor/consume-batch-when-available receive-queue event-handler) 0))) 到了这里，消息的发送与接收处理路径打通。

2016-09-13

欢迎来到2015 Twitter Flight开发者大会

【大咖・来了第7期】10月24日晚8点观看《智能导购对话机器人实践》北京时间10月22日凌晨每年一度的Twitter开发者大会在美国旧金山召开，旨在帮助开发者们了解更多关于如何使用Twitter平台打造最

2015-10-23

Twitter Storm安装配置（Ubuntu系统）单机版

我们需要从github上下载下来一个供初学者学习的storm-starter，同时，我们还需要有commons-collections-3.2.1-bin.tar.gz、twitter4j-2.2.6.

2015-05-07

IBM指控Twitter侵犯其至少三项专利

但对于将在本周登陆纽约证券交易所的Twitter来说，这份文件中所呈现出来的并非全是一边倒的好消息。

2013-11-05

Twitter Storm 实时数据处理框架分析总结

是Twitter开源的一个类似于Hadoop的实时数据处理框架（原来是由BackType开发，后BackType被Twitter收购，将Storm作为Twitter的实时数据分析）。

2013-04-11

Mastodon 4.0 RC1 发布，Twitter 开源替代品

这款诞生于 6 年前的开源软件，因为马斯克收购 Twitter 而在近期吸引了许多新用户。

2022-11-07

特斯拉 CEO 马斯克以 440 亿美元收购 Twitter

据外媒 BBC 报道，特斯拉 CEO 马斯克已经以每股 54.20 美元、总价 440 亿成功地完全收购了 Twitter，该公司随后将成为一家私人控股实体。

2022-04-26

Twitter承认错误验证了“少量”虚假账户

Twitter 本周一承认，它错误地验证了“少量”虚假账户。为此，平台以违反平台操纵和反垃圾邮件为由，永久停用了这些用户账号并取消了它们的蓝色徽章。

2021-07-13

Twitter 广告平台实时计费系统的架构增强之道

Twitter 是广告商吸引受众的一个热门平台。当广告商发起一个新的广告活动，它们会限定一个广告预算。Twitter 的广告服务器会检查广告活动的预算，以便确定是否还能继续投放广告。

2021-03-31

每日一博 | 给 Twitter 设计个安全修复方案

笔者看到Twitter内部这么久还没闭环，作为美国股市精神股东真替他们捉急。

2020-08-07

揭秘 Twitter 背后的基础设施：效率与优化篇

在这篇基础设施系列文章中，我主要聚焦于 Twitter 的一些关键设施和组件。

2017-06-05

探访美式微博Twitter的大数据技术架构

Twitter要上市了，再一次让全球瞩目，正是它所创造的twitte让互联网进入了微创新的时代。虽然它没有进入中国，但受其启发的新浪微博和腾讯微博在中国互联网上也成为一道亮丽的风景。

2017-04-02

马斯克宣布 Twitter 将改名为 X，并更换 Logo

更新：X Logo 已公布马斯克的推特头像和个人简介也已经更新：马斯克今日发布推文称，X.com 现已定向至 Twitter 原网址 twitter.com ，临时 X Logo 将于今日晚些时候启用

2023-07-24

马斯克指责 Meta 的 Threads 应用是在“窃取 Twitter”

埃隆·马斯克公开指责 Meta 是通过挖走 Twitter 核心员工来“窃取” 了 Twitter 的核心资源，然后推出了与 Twitter 类似的新社交媒体应用 Threads。

2023-07-08

Twitter 存在“限流”代码，连马斯克都不知情

Twitter 团队又发现了隐藏在源代码深处的一项「shadowbans」机制。「shadowbans」并非封禁用户，而是让你不容易看到这些用户的推文。

2023-06-19

Twitter的分布式自增ID算法snowflake (Java版)

而twitter的snowflake解决了这种需求，最初Twitter把存储系统从MySQL迁移到Cassandra，因为Cassandra没有顺序ID生成机制，所以开发了这样一套全局唯一ID生成服务。

2018-08-16

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。