Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work.
Claim your profile
Articles by Message msg
Affective Ruptures: A Proximity-Triggered Haptic Wearable
Things used in this project × 2 ERM vibration motor (coin type, 3V) × 1 NeoPixel LED strip, WS2812B, 7 LEDs × 1 × 1 × 2 × 2 × 1 Arduino IDE Libraries: Adafruit NeoPixel library, Grove Ultrasonic Ranger library (Seeed Studio) Public spaces are increasingly optimised for movement efficiency. You move through them quickly, quietly, without touching anything or anyone you did not intend to. The body in transit is a managed body.
RocketMQ(二)：原生API快速入门_rocketmq api-CSDN博客
RocketMQ系列文章 RocketMQ(一)：基本概念和环境搭建 RocketMQ(二)：原生API快速入门 一、RocketMQ快速入门 pom.xml <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>4.9.2</version> </dependency> @Test public void simpleProducer() throws Exception { DefaultMQProducer producer = new DefaultMQProducer("test-producer-group"); producer.setNamesrvAddr("localhost:9876"); producer.start(); Message message = new Message("testTopic", "我是一个简单的消息".getBytes()); SendResult sendResult =...
Surface Cracks Detection and Notification Systems with Blues
Things used in this project × 1 × 1 × 1 Raspberry Pi High Quality Camera × 1 × 1 × 1 GoPro Shorty Mini Extension Pole + Tripod × 1 × 1 × 1 A 50-year-old bridge collapsed in Pittsburgh (Pennsylvania) on January 28, 2022. There is only one reason why a sturdy structure such as a concrete bridge could suddenly collapse: wear and tear. Concrete structures generally start deteriorating after about 40 to 50 years.
TCP/UDP Socket、消息推送、自定义编码解码器（协议）
TCP/UDP Socket、消息推送、自定义编码解码器（协议） DatagramPacket类表示一个UDP数据包，包含了一个字节数组以及该数组的长度，还有源和目标的IP地址和端口号。是一种服务器向客户端推送实时更新的简单方式，它基于HTTP协议，但实现了类似WebSocket的服务器推送功能。它被设计用来解决传统HTTP协议中客户端向服务器发送请求、服务器响应后连接关闭的问题，从而实现了服务器可以主动向客户端推送数据的功能。客户端按照固定的时间间隔（例如，每几秒或几分钟）向服务器发送请求，以检查是否有新的消息或更新。服务器响应这些请求，返回客户端所需的数据。 复制链接
Android-Handler详解_原理解析_android handler-CSDN博客
逻辑层面的流程前一篇寄快递的举例描述大家肯定都已明了，这里我们从代码层面再串一下流程，并看看主流程中一些核心方法。为了方便阅读将文章分为使用篇和源码解析两篇，上一篇已经写了Handler是什么、有什么、怎们用，这一篇从源码的角度分析完整流程，看看Handler消息机制到底是啥原理。才疏学浅，如有错误，欢迎指正，多谢。 开发使用流程首先初始化Handler并new一个CallBack重写handleMessage或者run方法等着用来接收消息。 然后使用handler的sendMessage发送消息。 流程已经明确，涉及文件主要有Handler、Message、MessageQueue、Looper，开搞； 1.Handler 1.1 Handler类有个handleMessage方法，是个空方法，等后面子类重写该方法，调用方自己重写方法方便我们接收参数并进行处理。就是我们上一篇中3.1的方式一那个TestHandler中的handleMessage方法接收数据的回调。 1.2 Handler类内部有个接口，Callback，只有一个方法 boolean...
如何在 libevent 中读取超过 4096 字节的数据
bufferevent 是 libevent 中相对高层的封装，较 event 使用起来方便很多。 之前有一个需求，需要从服务端读取数据进行操作，为了防止数据过大，在 bufferevent 的 read_callback 中循环调用 bufferevent_read，期望多次通过调用来读完所有的数据。 很显然，这个方法不行，第二次调用 bufferevent_read 会被阻塞，不符合预期，不能够像调用 read(2) 那样来使用。 实际上，bufferevent 内有可读数据并且大于水位 watermask 才会调用 read_callback，在 read_callback 只能调用一次 bufferevent_read 来读出缓冲区内的数据。 当一次 bufferevent_read 不能全部读取完数据怎么办，网上有人通过骚操作去修改 EVBUFFER_MAX_READ 来调大单次读取的值，然后再进行编译。不可取的行为！！！ buffervent 中的 watermask 是触发 read_callback 的关键，我们只要 bufferevent 内的数据大于设置的...
2024安卓岗位面试题总结_2024android 面试-CSDN博客
数据结构 自动扩容: Collection - ArrayList 源码解析 栈操作 LinkedList<String> queue = new LinkedList<>(); queue.push("1"); queue.push("2"); queue.push("3"); System.out.println(queue.pop()); System.out.println(queue.pop()); System.out.println(queue.pop()); 双端队列 LinkedList<String> deque = new LinkedList<>(); deque.offerFirst("1"); deque.offerFirst("2"); deque.offerFirst("3"); System.out.println(deque.pollLast()); System.out.println(deque.pollLast()); System.out.println(deque.pollLast()); Collection -...
RocketMQ系统性学习-SpringCloud Alibaba集成RocketMQ以及顺序消费实战
欢迎关注公众号：【11来了】 发送 “资料” 可领取深入理解 Redis 系列文章结合电商场景讲解 Redis 使用场景、中间件系列笔记和编程高频电子书！ 作者为在读研究生，目前研二，计划在公众号记录学习常用中间件笔记，以及明年更新面试经历！ 顺序消费实战 顺序消费分为两种： 全局有序：适用于并发度不大，并且对消息要求严格一致性的场景下 通过创建一个 topic，并且该 topic 下只有一个队列，那么生产者向着一个队列中发消息，消费者也在这一个队列中消费消息，来保证消息的有序性 局部有序：适用于对性能要求比较高的场景，在设计层面将需要保证有序的消息放在 Topic 下的同一个队列即可保证有序 全局有序 要保证全局有序的话，我们先通过上边启动的 Dashboard 项目，创建一个只有一个队列的 Topic 将 写队列和读队列 都设置为 1 个，perm 设置为6（perm，2：只写； 4-只读； 6-读写；） 全局有序流程图如下： 首先消费者主启动类如下： @SpringBootApplication @EnableBinding({CustomSink.class })...
Netty（四）NIO-优化与源码-CSDN博客
Netty优化与源码 1.1 扩展序列化算法 序列化，反序列化主要用于消息正文的转换。 序列化：将java对象转为要传输对象(byte[]或json，最终都是byte[]) 反序列化：将正文还原成java对象。 byte[] body = new byte[bodyLength]; byteByf.readBytes(body); ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(body)); Message message = (Message) in.readObject(); message.setSequenceId(sequenceId); ByteArrayOutputStream out = new ByteArrayOutputStream(); new ObjectOutputStream(out).writeObject(message); byte[] bytes = out.toByteArray(); 为了支持更多序列化算法，抽象一个 Serializer...
【RocketMQ】顺序消息实现总结 - shanml - 博客园
全局有序 在RocketMQ中，如果使消息全局有序，可以为Topic设置一个消息队列，使用一个生产者单线程发送数据，消费者端也使用单线程进行消费，从而保证消息的全局有序，但是这种方式效率低，一般不使用。 局部有序 假设一个Topic分配了两个消息队列，生产者在发送消息的时候，可以对消息设置一个路由ID，比如想保证一个订单的相关消息有序，那么就使用订单ID当做路由ID，在发送消息的时候，通过订单ID对消息队列的个数取余，根据取余结果选择消息队列，这样同一个订单的数据就可以保证发送到一个消息队列中，消费者端使用MessageListenerOrderly处理有序消息，这就是RocketMQ的局部有序，保证消息在某个消息队列中有序。 接下来看RoceketMQ源码中提供的顺序消息例子（稍微做了一些修改）： 生产者 public class Producer { public static void main(String[] args) throws UnsupportedEncodingException { try { // 创建生产者 DefaultMQProducer...
Android Looper Handler 机制浅析
最近想写个播放器demo，里面要用到 Looper Handler，看了很多资料都没能理解透彻，于是决定自己看看相关的源码，并在此记录心得体会，希望能够帮助到有需要的人。 本文会以 猜想 + log验证 的方式来学习 Android Looper Handler，对于一些复杂的代码会进行跳过，能够理解它们的设计原理即可。本文观点皆个人拙见，如有错误恳请赐教。 Looper 在整个消息处理机制中起着 消息等待与消息分发 的作用： 消息等待：Looper 阻塞程序运行，等待即将到来的消息； 消息分发：Looper 收到消息后，将消息分发给指定处理者在当前线程处理。 首先来看阻塞的问题，app 启动时会创建一个 Looper，并且调用 loop 函数阻塞 main 函数，这个 Looper 被称为主线程/主进程 Looper，代码参考 ActivityThread.java ： public static void main(String[] args) { Trace.traceBegin(Trace.TRACE_TAG_ACTIVITY_MANAGER,...
Android FrameWork 层 Handler源码解析
Handler生产者-消费者模型 在android开发中，经常会在子线程中进行一些耗时操作，当操作完毕后会通过handler发送一些数据给主线程，通知主线程做相应的操作。 其中：子线程、handler、主线程，其实构成了线程模型中经典的生产者-消费者模型。 生产者-消费者模型：生产者和消费者在同一时间段内共用同一个存储空间，生产者往存储空间中添加数据，消费者从存储空间中取走数据。 保证数据生产消费的顺序（通过MessageQueue,先进先出） - 不管是生产者(子线程)还是消费者（主线程）都只依赖缓冲区（handler），生产者消费者之间不会相互持有，使他们之间没有任何耦合 。 Handler是Android消息管理机制，屏幕触摸事件、生命周期事件等都是封装成message，发送到handler进行处理。通过源码，我们进一步分析Handler的机制。 Handler机制 Hanlder：发送和接收消息； Looper：用于轮询消息队列，一个线程只能有一个Looper； Message： 消息实体； MessageQueue： 消息队列用于存储消息和管理消息 。 创建...
Handler机制（一）--Handler运行流程分析_一切皆是定数的博客-CSDN博客
1 概述 Handler机制是Android的异步消息处理机制，用于在线程间传递消息，主要涉及到四部分：Handler、Looper、Message和MessageQueue。其中Handler是消息的发送者和处理者；Message是消息主体；MessageQueue是消息队列，Handler发送的消息都会放入MessageQueue中等待处理；Looper是MessageQueue的管理者，里面有一个loop方法，无限循环的从MessageQueue中取出需要处理的消息（如果有），并交个Handler处理。...
【Netty 从成神到升仙系列 三】Netty 凭什么成为国内最流行的网络通信框架？
wx646db0e245a37 2023-05-24 14:59:18 博主文章分类：网络编程 ©著作权 文章标签 java 大数据 开发语言 面试 分布式 文章分类 JavaScript 前端开发 ©著作权归作者所有：来自51CTO博客作者wx646db0e245a37的原创作品，请联系作者获取转载授权，否则将追究法律责任 文章目录 Netty 源码 一、源码构成 二、Netty对三种I/O的支持 1、三种模式如何切换 三、Netty 如何支持 Reactor 模型 1. EventLoop 是线程嘛 2. 如何实现三种模式的 Reactor 模型 2.1 单线程 Reactor 模式 2.2 多线程 Reactor 模式 2.3 主从 Reactor 模式 2.3.1 主从模式如何实现 2.3.2 主从模式源码实现 3. Netty 给 Channel 分配 NIOEventLoop 的规则 3.1 GenericEventExecutorChooser 3.2 PowerOfTwoEventExecutorChooser 4.
Netty服务端开发及性能优化 | 京东云技术团队
文章目录 1. 创建服务端 2. 编码和解码 3. 添加业务处理Handler 4. ChannelHandler的生命周期 5. 解决粘包和半包问题 6. Netty性能优化 7. ChannelPipeline 8. Reactor线程模型 京东云开发者 2023-05-04 15:29:02 博主文章分类：技术分享 ©著作权 文章标签 Netty 文章分类 软件研发 yyds干货盘点 ©著作权归作者所有：来自51CTO博客作者京东云开发者的原创作品，请联系作者获取转载授权，否则将追究法律责任 作者：京东物流 王奕龙 Netty是一个异步基于事件驱动的高性能网络通信框架，可以看做是对NIO和BIO的封装，并提供了简单易用的API、Handler和工具类等，用以快速开发高性能、高可靠性的网络服务端和客户端程序。 1.
RocketMQ的简单使用 - Leo哥coding~ - 博客园
领域模型介绍 Producer: 用于生产消息的运行实体。 Topic: 主题，用于消息传输和存储的分组容器。 MessageQueue: 消息传输和存储的实际单元容器。 Message: 消息传输的最小单元。 ConsumerGroup: 消费者组。 Consumer: 消费者。 Subscription: 订阅关系，发布订阅模式中消息过滤、重试、消费进度的规则配置。 MQ的优势 MQ的明显优势有3个。 应用解耦： 以多服务为例，用户下单，需要通知订单服务和库存服务，我们可以通过MQ消息来解除下单和库存系统的耦合。 异步提速： 以秒杀为例，我们可以先返回秒杀结果，后续再通过MQ异步消息去插入记录和扣减库存等，减少调用的链路长度。 削峰填谷： 将某一时间内的请求量分摊到更多时间处理，比如系统A一秒只能处理10000个请求，但是我有100000个请求需要处理，我可以将请求发到MQ中，再分成10秒去消费这些请求。 当然MQ也有劣势，系统可用性降低，系统复杂度提高，一致性问题。 RocketMQ的主要角色 主要包括Producer、Broker、Consumer、NameServer...
flink 整合rocketmq
下面代码路径 ：source->rocketmq->common->selector DefaultTopicSelector.java 类 public class DefaultTopicSelector<T> implements TopicSelector<T> { private final String topicName; private final String tagName; public DefaultTopicSelector(final String topicName) { this(topicName, ""); } public DefaultTopicSelector(String topicName, String tagName) { this.topicName = topicName; this.tagName = tagName; } @Override public String getTopic(T tuple) { return topicName; } @Override public String getTag(T...
From Alibaba to Apache: RocketMQ’s Past, Present, and Future
Key Takeaways From Alibaba to Apache, RocketMQ has evolved through three generations. RocketMQ, as a high throughput, high reliability, and low latency distributed MOM, consists of four parts: Name Servers, Brokers, Producers and Consumers. During the 2016 global Nov. 11 Shopping Festival, RocketMQ has handled 1.2 trillion message transmissions, almost twice as much as of 2015.
Show More
loading
Actions
Is this you?
As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work.Get in touch with Message
Contact Message, search articles and posts on X, monitor coverage, and track replies from one place.
Learn more about Muck Rack