皮皮网

1.什么叫EMQ
2.用Java实现Actor模型（模仿Skynet）

什么叫EMQ

        EMQ是基于高并发的Erlang/OTP语言平台设计，支持百万级连接和分布式集群，发布订阅模式的开源MQTT消息服务器

        完整支持MQTT V3.1/V3.1.1协议规范，扩展支持WebSocket、Stomp、CoAP、MQTT-SN或私有TCP协议

        完全开放源码

        基于Apache Version 2.0开源协议

        百万级并发连接

       

        单节点万并发MQTT连接峰值负载

        完整MQTT协议支持

        MQTT V3.1.1协议规范QoS0/1/2消息支持

        简便安装部署

        跨平台部署在Linux、FreeBSD、Mac OS X或Windows服务器

        分布式集群或桥接

        双节点负载均衡或多节点分布式集群

        扩展模块与插件

        LDAP,源码 MySQL, PostgreSQL, Redis, MongoDB扩展插件集成

        EMQ! 给分给分给分！

用Java实现Actor模型（模仿Skynet）

       Actor模型是种常见的并发模型，与共享内存（同步锁）不同，源码它将程序划分为多个独立计算单元——Actor，源码每个Actor独立管理资源，源码不同Actor间通过消息传递交互。源码优势在于全异步执行，源码java电商项目源码下载避免线程阻塞，源码提高CPU使用率，源码且无需考虑加锁和线程同步问题。源码

       Actor模型在业界应用广泛，源码如游戏服务器框架Skynet、源码编程语言Erlang。源码Java下应用较少，源码知名的源码是基于Scala的Akka。但Actor模型并非万能，源码异步编程需编写更多回调代码，原本一步拆成多步，带麻将游戏源码增加代码复杂度。

       本文以学习研究目的，使用Java实现简化Actor模型，功能模仿Skynet，包括：

       完整源代码在GitHub可获取。关键代码与设计思路如下。

       Actor是Actor模型核心概念，每个Actor管理资源，php解除授权源码与其它Actor通过Message通信。

       Actor由单线程驱动，类为抽象，处理消息的`handleMessage`方法需具体类重载实现。

       Node代表独立Java进程，有自己的IP和端口，内部可运行多个Actor。Node间通过异步网络通信发送消息，bigsur编译android源码Actor仅绑定一个Node。

       ActorSystem是Actor管理系统，外部调用API入口，提供创建Actor、发送消息、休眠等功能。

       ActorSystem初始化分为三步：读取集群配置、绑定Node、整点视频app源码初始化自身，包括定时器和Netty服务端初始化。Node间通信异步，客户端和服务端使用Netty做。

       创建Actor调用`newActor`方法，指定具体类和Actor名，确保Node内唯一。创建时绑定Node，调用`start`方法初始化，将名与Actor映射。

       发送消息核心是`send`方法，指定目标Node、Actor名、命令名和参数，可封装为Message。

       `currThreadActor`变量记录当前线程的Actor，简化消息发送时指定来源信息。若目标与来源相同，直接添加消息；否则，通过网络通信实现，使用Netty做序列化和反序列化。

       休眠Actor通过`sleep`方法实现，指定毫秒数、回调命令及参数。底层通过定时任务实现阻塞。

       ActorSystem使用定时器管理定时任务，添加新任务后轮询处理。考虑优化避免多线程同时创建Channel。

       程序示例在test包内，启动Node后打印日志，验证Actor模型工作方式。

       总结，本文展示了使用Java实现简化Actor模型的完整流程，实现基础功能。造轮子旨在深入理解Actor模型，语言只是实现工具。相信本文有助于读者深入理解Actor模型。