`
hideto
  • 浏览: 2675004 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

gen_server入门

阅读更多
gen_server入门

1)什么是gen_server?
gen_server是OTP(Open Telecom Platform)的一个组件,OTP是Erlang的应用程序框架,gen_server定义了自己的一套规范,用来写Erlang服务器程序
gen_server manual: http://www.erlang.org/doc/man/gen_server.html

2)使用gen_server程序的三个步骤:
1,为callback module起个名字
2,写接口function
3,在callback module里写6个必需的callback function

3)behaviour
关键字-behaviour供编译器使用,如果我们的gen_server程序没有定义合适的callback function则编译时会出错误和警告

4)gen_server模板
%%%-------------------------------------------------------------------
%%% File    : gen_server_template.full
%%% Author  : my name <yourname@localhost.localdomain>
%%% Description : 
%%%
%%% Created :  2 Mar 2007 by my name <yourname@localhost.localdomain>
%%%-------------------------------------------------------------------
-module().

-behaviour(gen_server).

%% API
-export([start_link/0]).

%% gen_server callbacks
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
	 terminate/2, code_change/3]).

-record(state, {}).

%%====================================================================
%% API
%%====================================================================
%%--------------------------------------------------------------------
%% Function: start_link() -> {ok,Pid} | ignore | {error,Error}
%% Description: Starts the server
%%--------------------------------------------------------------------
start_link() ->
    gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).

%%====================================================================
%% gen_server callbacks
%%====================================================================

%%--------------------------------------------------------------------
%% Function: init(Args) -> {ok, State} |
%%                         {ok, State, Timeout} |
%%                         ignore               |
%%                         {stop, Reason}
%% Description: Initiates the server
%%--------------------------------------------------------------------
init([]) ->
    {ok, #state{}}.

%%--------------------------------------------------------------------
%% Function: %% handle_call(Request, From, State) -> {reply, Reply, State} |
%%                                      {reply, Reply, State, Timeout} |
%%                                      {noreply, State} |
%%                                      {noreply, State, Timeout} |
%%                                      {stop, Reason, Reply, State} |
%%                                      {stop, Reason, State}
%% Description: Handling call messages
%%--------------------------------------------------------------------
handle_call(_Request, _From, State) ->
    Reply = ok,
    {reply, Reply, State}.

%%--------------------------------------------------------------------
%% Function: handle_cast(Msg, State) -> {noreply, State} |
%%                                      {noreply, State, Timeout} |
%%                                      {stop, Reason, State}
%% Description: Handling cast messages
%%--------------------------------------------------------------------
handle_cast(_Msg, State) ->
    {noreply, State}.

%%--------------------------------------------------------------------
%% Function: handle_info(Info, State) -> {noreply, State} |
%%                                       {noreply, State, Timeout} |
%%                                       {stop, Reason, State}
%% Description: Handling all non call/cast messages
%%--------------------------------------------------------------------
handle_info(_Info, State) ->
    {noreply, State}.

%%--------------------------------------------------------------------
%% Function: terminate(Reason, State) -> void()
%% Description: This function is called by a gen_server when it is about to
%% terminate. It should be the opposite of Module:init/1 and do any necessary
%% cleaning up. When it returns, the gen_server terminates with Reason.
%% The return value is ignored.
%%--------------------------------------------------------------------
terminate(_Reason, _State) ->
    ok.

%%--------------------------------------------------------------------
%% Func: code_change(OldVsn, State, Extra) -> {ok, NewState}
%% Description: Convert process state when code is changed
%%--------------------------------------------------------------------
code_change(_OldVsn, State, _Extra) ->
    {ok, State}.

%%--------------------------------------------------------------------
%%% Internal functions
%%--------------------------------------------------------------------


gen_server:start_link(Name, Mod, InitArgs, Opts)创建一个名为Name的server,callback moudle为Mod
Mod:init(InitArgs)启动server
client端程序调用gen_server:call(Name, Request)来调用server,server处理逻辑为handle_call/3
gen_server:cast(Name, Name)调用callback handle_cast(_Msg, State)以改变server状态
handle_info(_Info, State)用来处理发给server的自发消息
terminate(_Reason, State)是server关闭时的callback
code_change是server热部署或代码升级时做callback修改进程状态

5)my_bank例子
%% ---
%%  Excerpted from "Programming Erlang",
%%  published by The Pragmatic Bookshelf.
%%  Copyrights apply to this code. It may not be used to create training material, 
%%  courses, books, articles, and the like. Contact us if you are in doubt.
%%  We make no guarantees that this code is fit for any purpose. 
%%  Visit http://www.pragmaticprogrammer.com/titles/jaerlang for more book information.
%%---
-module(my_bank).

-behaviour(gen_server).
-export([start/0]).
%% gen_server callbacks
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
	 terminate/2, code_change/3]).
-compile(export_all).


start() -> gen_server:start_link({local, ?MODULE}, ?MODULE, [], []).
stop()  -> gen_server:call(?MODULE, stop).

new_account(Who)      -> gen_server:call(?MODULE, {new, Who}).
deposit(Who, Amount)  -> gen_server:call(?MODULE, {add, Who, Amount}).
withdraw(Who, Amount) -> gen_server:call(?MODULE, {remove, Who, Amount}).



init([]) -> {ok, ets:new(?MODULE,[])}.

handle_call({new,Who}, _From, Tab) ->
    Reply = case ets:lookup(Tab, Who) of
		[]  -> ets:insert(Tab, {Who,0}), 
		       {welcome, Who};
		[_] -> {Who, you_already_are_a_customer}
	    end,
    {reply, Reply, Tab};
handle_call({add,Who,X}, _From, Tab) ->
    Reply = case ets:lookup(Tab, Who) of
		[]  -> not_a_customer;
		[{Who,Balance}] ->
		    NewBalance = Balance + X,
		    ets:insert(Tab, {Who, NewBalance}),
		    {thanks, Who, your_balance_is,  NewBalance}	
	    end,
    {reply, Reply, Tab};
handle_call({remove,Who, X}, _From, Tab) ->
    Reply = case ets:lookup(Tab, Who) of
		[]  -> not_a_customer;
		[{Who,Balance}] when X =< Balance ->
		    NewBalance = Balance - X,
		    ets:insert(Tab, {Who, NewBalance}),
		    {thanks, Who, your_balance_is,  NewBalance};	
		[{Who,Balance}] ->
		    {sorry,Who,you_only_have,Balance,in_the_bank}
	    end,
    {reply, Reply, Tab};
handle_call(stop, _From, Tab) ->
    {stop, normal, stopped, Tab}.

handle_cast(_Msg, State) -> {noreply, State}.
handle_info(_Info, State) -> {noreply, State}.
terminate(_Reason, _State) -> ok.
code_change(_OldVsn, State, Extra) -> {ok, State}.


6)编译运行my_bank:
Eshell > c(my_bank).
Eshell > my_bank:start().
Eshell > my_bank:new_account("hideto").
Eshell > my_bank:deposit("hideto", 100).
Eshell > my_bank:deposit("hideto", 200).
Eshell > my_bank:withdraw("hideto", 10).
Eshell > my_bank:withdraw("hideto", 10000).


gen_server可以在多个node上做分布计算,而ets(Erlang term storage)这种内存式BigTable可以负责高性能数据存取,所以gen_server+ets特别适合FreeWheel的forecasting模块:)
分享到:
评论

相关推荐

    erlang的翻译文档

    - **Gen_Server 行为**:文档中未给出具体细节,但通常涉及服务器进程的设计和实现。 - **Gen_Fsm 行为** - **有限状态机**:介绍了如何使用Gen_Fsm实现状态机逻辑。 - **示例**:提供了Gen_Fsm的具体用法示例。 ...

    HP Proliant Microserver Gen8 WIN2008R2 WIN7阵列卡驱动下载

    在IT领域,服务器硬件的正确配置与驱动程序的安装至关重要,尤其是对于中小企业来说,HP Proliant Microserver Gen8 是一款性价比极高的入门级服务器。这款服务器在处理日常业务、数据存储以及小型网络环境下的应用...

    Erlang中文手册.pdf

    - **2.2 Gen_Server Behaviour**:文档缺失,未提供具体细节。 - **2.3 Gen_Fsm Behaviour**:讲解如何使用有限状态机行为。 - **2.3.1 有限状态机**:Erlang中的Gen_Fsm行为允许实现有限状态机。 - **2.3.2 实例*...

    Erlang入门:构建application练习5(监督树)

    2. **模块(`.erl`)**:实际实现功能的代码,可以是普通的函数模块,也可以是行为模块(如gen_server,gen_event等)。 3. **启动脚本(`.boot`)**:指定启动应用时的初始状态,包括启动哪些进程及其顺序。 4. *...

    Erlang中文手册

    - **Gen_Server**: 用于实现通用服务器行为。 - **功能**: - 处理客户端请求。 - 维护内部状态。 - 支持错误处理和重启策略。 **2.3 Gen_Fsm Behaviour** - **2.3.1 有限状态机** - **定义**: 一种数学模型,...

    sqlserver2019中文帮助(带书签,高清)

    文档提供了使用curl、SQL、Spark加载数据的方法,以及如何为HDFS分层装入数据到Azure Data Lake Gen2或S3。 【机器学习服务】支持Python和R,提供了快速入门教程,涵盖数据探索、建模、训练和评分。用户可以使用T-...

    HPE_a00018261zh_cn_Smart Update Manager 入门指南.pdf

    HPE Smart Update Manager 入门指南 HPE Smart Update Manager 是 Hewlett Packard Enterprise 发布的一款集成了服务器更新管理功能的工具,旨在帮助用户快速地将固件和软件更新应用于 HPE Synergy、Edgeline 和 ...

    HP ML10 和ML110G7安装2003的方法

    ML110G7是惠普(HP)公司生产的一款入门级服务器,其硬件配置包括Intel E3处理器、Intel C200芯片组和HP SATA RAID B110i阵列控制器。这个型号的服务器在设计时可能未考虑对Windows Server 2003操作系统的直接支持,...

    HP Connection Unity(Microserver Gen8可用)

    HP Microserver Gen8作为一款面向小型企业或个人用户的入门级服务器,其特点在于经济实惠、易于维护和扩展。然而,对于网络连接的管理,如果没有专门的工具,可能会变得复杂且效率低下。HP Connection Unity正好解决...

    android入门-f1

    2. **gen**:这个目录是自动生成的,包含了R.java文件,它是Android资源的ID集合,开发者无需手动创建。 3. **res**:资源目录,包含图像、布局、字符串等所有资源文件。布局文件通常在`res/layout`下,字符串在`res...

    HPE StoreEasy 1000 Storage 快速入门指南.pdf

    根据提供的文件内容,我们可以提炼出关于HPE StoreEasy 1000 Storage快速入门指南的知识点,具体如下: 1. HPE StoreEasy 1000 Storage介绍: HPE StoreEasy 1000 Storage是一系列由惠普企业(Hewlett Packard ...

    图书:JSF2 API和JBoss Seam入门

    《JSF2 API和JBoss Seam入门》是一本面向初学者和中级开发者的图书,旨在帮助读者快速掌握JavaServer Faces(JSF)2.0 API和JBoss Seam框架的使用。JSF是一种Java EE标准的用户界面组件模型,用于构建Web应用程序。...

    Seam简单入门学习教程.docx

    Seam还提供了一些工具,如Seam Gen,可以帮助快速生成项目模板,包括所有必要的配置文件。这使得开发者能够快速启动新项目,而不需要从头开始构建基础架构。 总的来说,Seam通过减少繁琐的底层集成工作,使开发者...

    H3C红牌与HPE绿牌产品对应关系表-20210512.pdf

    首先,H3C的FlexServer R390对应于HPE的DL380p Gen8,这两款服务器均定位为企业级的入门级双插槽服务器,适合轻量级工作负载。R590则对应于HPE的DL560 Gen8,它们都是四插槽服务器,适合需要更高性能的企业应用。 ...

    n2o_skeleton:基于http的N2O应用骨架

    开发者可以通过定义Erlang行为(如gen_server)来实现业务逻辑,然后通过N2O的路由系统将HTTP请求映射到相应的处理函数。 **五、CSS在N2O中的应用** 作为标签中提到的一个关键点,CSS在构建Web界面时起着至关重要的...

Global site tag (gtag.js) - Google Analytics