知识模块-并发编程.md · 波哥大/大数据笔记 - Gitee.com

加入 Gitee

与超过 1200万开发者一起发现、参与优秀开源项目，私有仓库也完全免费：）

文件

克隆/下载

知识模块-并发编程.md 1.21 KB

一键复制编辑原始数据按行查看历史

提交于 2021-04-18 22:26 +08:00 . Hbase Kafka

# 并发编程

```scala
case class  vs  case object
# case class 可以带信息
```

## 通信

- Netty
- (***)Akka： 基于Actor【编程重点】编程模型  
  - https://akka.io/
- Mina

### 消息传递 

#### Actor

- “人”  "类" 
- 学员是一个Actor   我也是一个Actor
- 用于接收、发送消息[**case class/case object**]
- Actor有一个管理者： 创建Actor、管理Actor

#### 通信：是通过消息指令来完成   并发

NN DN
RM NM
Master Worker
Leader Follower

![](./pictures/并发aka.jpg)



### Pom.xml

```xml
 <dependency>
   <groupId>com.typesafe.akka</groupId>
   <artifactId>akka-actor_${scala.tools.version}</artifactId>
   <version>2.5.21</version>
</dependency>
<dependency>
  <groupId>com.typesafe.akka</groupId>
  <artifactId>akka-remote_${scala.tools.version}</artifactId>
  <version>2.5.21</version>
</dependency>
```





## 使用ZK来实现分布式锁的思路

​	client1： 
​		创建一个临时顺序节点
​		判断是否加锁： 是不是最小的
​			ok ==> 加锁
​		业务处理完之后： 释放锁
​	client2：
​		创建一个临时顺序节点
​		判断是否加锁： 是不是最小的
​			不是最小的
​				找它的上一个节点 + 监听器

Loading...

马建仓 AI 助手

尝试更多

代码解读

代码找茬

代码优化

Java

1

https://gitee.com/AndyWu93/big-data-notes.git

git@gitee.com:AndyWu93/big-data-notes.git

AndyWu93

big-data-notes

大数据笔记

master