elixir 高可用系列(一) Agent

来源:http://www.cnblogs.com/wang_yb/archive/2016/04/22/5422683.html
-Advertisement-
Play Games

概述 elixir 本身是一種 immutable 的語言,預設情況下,進程間是不共用任何狀態的,進程之間通過消息來交互。 而 Agent 則封裝了一種進程間共用狀態的方式,通過這種方式,不用顯式的寫 send/receieve 的代碼,就能方便的在進程之間共用狀態。 使用方法 不用 Agent 來 ...


概述

elixir 本身是一種 immutable 的語言,預設情況下,進程間是不共用任何狀態的,進程之間通過消息來交互。
而 Agent 則封裝了一種進程間共用狀態的方式,通過這種方式,不用顯式的寫 send/receieve 的代碼,就能方便的在進程之間共用狀態。

使用方法

不用 Agent 來管理狀態

首先,看一個在不用 Agent 的情況下,如何獲取進程狀態的例子。

defmodule WithoutAgent do
  def start do
    Map.new()
  end

  def get(map, key) do
    if Map.has_key?(map, key) do
      Map.get(map, key)
    else
      nil
    end
  end

  def put(map, key, val) do
    Map.put(map, key, val)
  end

  def delete(map, key) do
    Map.delete(map, key)
  end
end

測試 WithoutAgent 的使用:

iex> m = WithoutAgent.start
%{}
iex> WithoutAgent.get(m, "map-key")
nil

iex> m = WithoutAgent.put(m, "map-key", "map-val")
%{"map-key" => "map-val"}
iex> WithoutAgent.get(m, "map-key")
"map-val"

iex> m = WithoutAgent.delete(m, "map-key")
%{}
iex> m = WithoutAgent.get(m, "map-key")
nil

從上面的使用可以看出,為了使用 WithoutAgent 中的狀態(一個 map),外部還必須要自己管理 WithoutAgent 的返回的狀態 m,
通過 WithoutAgent 來改變狀態時,每次都要將當前狀態 m 作為一個參數傳給 WithoutAgent。

只有一個進程使用 WithoutAgent 時,上述方式沒有什麼問題,當有多個進程使用 WithoutAgent,每個進程持有的狀態 m 很難保持一致。

使用 Agent 來管理狀態

elixir 中的 Agent 其實並不是 elixir 發明的新東西,而是封裝了 erlang OTP 中現有的 ETS (Erlang Term Storage)
使用 Agent 來重新實現上面的例子:

defmodule WithAgent do
  def start do
    Agent.start_link(fn -> Map.new end, name: __MODULE__)
  end

  def get(key) do
    Agent.get(__MODULE__, fn map ->
      if Map.has_key?(map, key) do
        Map.get(map, key)
      else
        nil
      end
    end)
  end

  def put(key, val) do
    Agent.update(__MODULE__, &Map.put(&1, key, val))
  end

  def delete(key) do
    Agent.get_and_update(__MODULE__, fn map ->
      if Map.has_key?(map, key) do
        Map.pop(map, key)
      else
        nil
      end
    end)
  end
end

測試 WithAgent 的使用:

iex> WithAgent.start
{:ok, #PID<0.108.0>}
iex> WithAgent.get("map-key")
nil

iex> WithAgent.put("map-key", "map-val")
:ok
iex> WithAgent.get("map-key")
"map-val"

iex> WithAgent.delete("map-key")
"map-val"
iex> WithAgent.get("map-key")
nil

從上面的使用中可以看出,使用了 Agent 之後,使用方完全不用自己管理 WithAgent 的狀態,只要操作狀態即可。
這樣,多個進程同時使用 WithAgent 時,也不用管狀態衝突的事情,狀態如果有衝突也是在 WithAgent 中自己管理。

總結

總的來說,Agent 就是狀態的簡單的封裝,方便進程間狀態的共用。
此外,除了上面用的方法,Agent 中的所有方法參照:Agent


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • atitit.詞法分析原理 詞法分析器 (Lexer) 1. 詞法分析(英語:lexical analysis)1 2. ;實現詞法分析程式的常用途徑:自動生成,手工生成.[1] 2 2.1. 詞法分析程式的功能2 2.2. 如何描述詞素3 2.3. 單詞token3 2.4. Token的類型,根 ...
  • 註:以下文章原文來自於Dr Charles Severance 的 《Python for Informatics》 本書中的許多例子關註的是讀取文件並查找數據,但在互聯網中還有許多不同信息源。 本章我們將偽裝成瀏覽器用超文本傳送協議(HTTP)從網站獲取網頁,通讀並分析它。 12.1 超文本傳送協 ...
  • 引言 - 為尋一顆明星 { 風 : http://music.163.com/#/song?id=5276735 } 前言 - 有點扯 C基本是程式生涯的入門語言. 雖說簡單, 但已經斷層了. 估計是不合時宜吧. 工作中也就在網路層框架會看見部分C的影子. 自己用C開發久了, 發現C一個弊端是 當一 ...
  • 問題的描述: 一個項目,涉及到了 兩個數據源,分別使用的是 兩個不同的 資料庫連接池,其中一個是 poxool 連接池,問題在於,spring在啟動時,只初始化其中的一個 資料庫連接池中的資料庫連接,而 poxool配置的資料庫連接池,在啟動時 沒有進行初始化,一個資料庫連接也沒有初始化好,所以導致 ...
  • 本文章向碼農介紹Typecho 博客文章瀏覽次數統計插件Stat,需要的碼農可以參考一下。 我的新博客使用的博客系統是Typecho博客系統,使用的時候發現,該博客系統本身沒有文章瀏覽統計功能,很不習慣。在網上搜了下後發現,有相關的博客插件可以實現,插件的使用很簡單,博客吧在這裡簡單說明下Typec ...
  • 第一步:配置防火牆(預設情況下,埠80和3306是拒絕訪問的,在防火牆上進行配置): vi /etc/sysconfig/iptables(在"COMMIT"的上一行加上如下兩句) -A INPUT -m state --state NEW -m tcp -p tcp --dport 80 -j  ...
  • Delphi XE10支持MongoDB的資料庫,提供了個例子restaurants可批量導入數據。 本文對比Delphi例子與MongoDB自帶的mongoimport導入批量數據的性能。 步驟: 1.運行例子前需要先安裝MongoDB, MongoDB安裝及運行mongod.exe,安裝完成後b ...
  • 控制反轉(Inversion of Control,英文縮寫為IoC)是一個重要的面向對象編程的法則來削減電腦程式的耦合問題,也是輕量級的Spring框架的核心。 控制反轉一般分為兩種類型,依賴註入(Dependency Injection,簡稱DI)和依賴查找。依賴註入應用比較廣泛。把控制權從具 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...