- 浏览: 2675004 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
80后的童年2:
深入浅出MongoDB应用实战开发网盘地址:https://p ...
MongoDB入门教程 -
shliujing:
楼主在不是精通java和php的前提下,请不要妄下结论。
PHP、CakePHP哪凉快哪呆着去 -
安静听歌:
希望可以一给一点点注释
MySQL存储过程之代码块、条件控制、迭代 -
qq287767957:
PHP是全宇宙最强的语言!
PHP、CakePHP哪凉快哪呆着去 -
rryymmoK:
深入浅出MongoDB应用实战开发百度网盘下载:链接:http ...
MongoDB入门教程
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模板
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例子
6)编译运行my_bank:
gen_server可以在多个node上做分布计算,而ets(Erlang term storage)这种内存式BigTable可以负责高性能数据存取,所以gen_server+ets特别适合FreeWheel的forecasting模块:)
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模块:)
发表评论
-
ECUG III -- Elrang中国用户组第三次活动
2008-11-06 11:00 2230详情请见: http://ecug.org/ 大家也帮忙宣传 ... -
Erlang内存管理和运行模式笔记
2008-09-25 16:40 5369Erlang进程非常轻量级 进程间通过消息传递进行通讯 进程接 ... -
Erlang:一个通用的网络服务器
2008-09-24 16:50 6097原文: Erlang: A Generalized TCP S ... -
Erlang里的make
2008-09-22 17:38 3718Erlang自带一个make工具 我们看一个例子 目录结构: ... -
介绍Erlang里的Record
2008-09-12 15:52 8577原文: Erlang: An Introduction to ... -
Erlang与ActionScript3采用JSON格式进行Socket通讯
2008-09-02 16:37 6254前提: 需要下载as3corelib来为ActionScrip ... -
Erlang的JSON库
2008-09-02 15:40 9338使用下列JSON库: http://www.lshift.ne ... -
Erlang和ActionScript3的Socket通讯
2008-09-02 13:18 2871server.erl -module(server). ... -
Erlang和Ruby的Socket通讯
2008-09-01 22:12 2313server.erl -module(server). ... -
Erlang实现简单Web服务器
2008-09-01 17:59 5771转贴一个简单的Web服务器: httpd.erl %% h ... -
Mnesia用户手册:五,Mnesia高级特性
2008-09-01 17:27 7043本章描述了构建分布式、容错的Mnesia数据库相关的高级特性: ... -
Mnesia用户手册:四,事务和其他访问上下文
2008-08-29 00:06 6777本章讲述Mnesia事务系统和事务属性,它们让Mnesia成为 ... -
Mnesia用户手册:三,构建Mnesia数据库
2008-08-27 21:46 9183本章详细介绍了设计Mnes ... -
Mnesia用户手册:二,Mnesia快速上手
2008-08-27 14:09 9076本章介绍了Mnesia: 1) ... -
Mnesia用户手册:一,介绍
2008-08-26 15:47 7776Mnesia是一个分布式数据 ... -
OTP Design Principles: Supervisor Behaviour
2008-08-26 00:06 3088Supervisor Behaviour是一个用来实现一个su ... -
gen_event例子:terminal_logger
2008-08-25 16:23 1641定义三个terminal_logger: $$ termina ... -
OTP Design Principles: Gen_Event Behaviour
2008-08-25 16:06 17941,事件处理原则 在OTP里,event manager是一个 ... -
gen_fsm例子:code_lock
2008-08-22 18:35 2122改了一下代码,可以run了: %% code_lock.erl ... -
OTP Design Principles: Gen_Fsm Behaviour
2008-08-22 17:29 17911,有限状态机 FSM,有 ...
相关推荐
- **Gen_Server 行为**:文档中未给出具体细节,但通常涉及服务器进程的设计和实现。 - **Gen_Fsm 行为** - **有限状态机**:介绍了如何使用Gen_Fsm实现状态机逻辑。 - **示例**:提供了Gen_Fsm的具体用法示例。 ...
在IT领域,服务器硬件的正确配置与驱动程序的安装至关重要,尤其是对于中小企业来说,HP Proliant Microserver Gen8 是一款性价比极高的入门级服务器。这款服务器在处理日常业务、数据存储以及小型网络环境下的应用...
- **2.2 Gen_Server Behaviour**:文档缺失,未提供具体细节。 - **2.3 Gen_Fsm Behaviour**:讲解如何使用有限状态机行为。 - **2.3.1 有限状态机**:Erlang中的Gen_Fsm行为允许实现有限状态机。 - **2.3.2 实例*...
2. **模块(`.erl`)**:实际实现功能的代码,可以是普通的函数模块,也可以是行为模块(如gen_server,gen_event等)。 3. **启动脚本(`.boot`)**:指定启动应用时的初始状态,包括启动哪些进程及其顺序。 4. *...
- **Gen_Server**: 用于实现通用服务器行为。 - **功能**: - 处理客户端请求。 - 维护内部状态。 - 支持错误处理和重启策略。 **2.3 Gen_Fsm Behaviour** - **2.3.1 有限状态机** - **定义**: 一种数学模型,...
文档提供了使用curl、SQL、Spark加载数据的方法,以及如何为HDFS分层装入数据到Azure Data Lake Gen2或S3。 【机器学习服务】支持Python和R,提供了快速入门教程,涵盖数据探索、建模、训练和评分。用户可以使用T-...
HPE Smart Update Manager 入门指南 HPE Smart Update Manager 是 Hewlett Packard Enterprise 发布的一款集成了服务器更新管理功能的工具,旨在帮助用户快速地将固件和软件更新应用于 HPE Synergy、Edgeline 和 ...
ML110G7是惠普(HP)公司生产的一款入门级服务器,其硬件配置包括Intel E3处理器、Intel C200芯片组和HP SATA RAID B110i阵列控制器。这个型号的服务器在设计时可能未考虑对Windows Server 2003操作系统的直接支持,...
HP Microserver Gen8作为一款面向小型企业或个人用户的入门级服务器,其特点在于经济实惠、易于维护和扩展。然而,对于网络连接的管理,如果没有专门的工具,可能会变得复杂且效率低下。HP Connection Unity正好解决...
2. **gen**:这个目录是自动生成的,包含了R.java文件,它是Android资源的ID集合,开发者无需手动创建。 3. **res**:资源目录,包含图像、布局、字符串等所有资源文件。布局文件通常在`res/layout`下,字符串在`res...
根据提供的文件内容,我们可以提炼出关于HPE StoreEasy 1000 Storage快速入门指南的知识点,具体如下: 1. HPE StoreEasy 1000 Storage介绍: HPE StoreEasy 1000 Storage是一系列由惠普企业(Hewlett Packard ...
《JSF2 API和JBoss Seam入门》是一本面向初学者和中级开发者的图书,旨在帮助读者快速掌握JavaServer Faces(JSF)2.0 API和JBoss Seam框架的使用。JSF是一种Java EE标准的用户界面组件模型,用于构建Web应用程序。...
Seam还提供了一些工具,如Seam Gen,可以帮助快速生成项目模板,包括所有必要的配置文件。这使得开发者能够快速启动新项目,而不需要从头开始构建基础架构。 总的来说,Seam通过减少繁琐的底层集成工作,使开发者...
首先,H3C的FlexServer R390对应于HPE的DL380p Gen8,这两款服务器均定位为企业级的入门级双插槽服务器,适合轻量级工作负载。R590则对应于HPE的DL560 Gen8,它们都是四插槽服务器,适合需要更高性能的企业应用。 ...
开发者可以通过定义Erlang行为(如gen_server)来实现业务逻辑,然后通过N2O的路由系统将HTTP请求映射到相应的处理函数。 **五、CSS在N2O中的应用** 作为标签中提到的一个关键点,CSS在构建Web界面时起着至关重要的...