使用erlang ranch tcp开发服务端

http://blog.csdn.net/huang1196/article/details/38401197

Ranch：

简单来说，Ranch就是一个tcp acceptor pool，用于高并发下的tcp连接建立与管理。可以设置并发链接最大数量，在不关闭socket连接的情况下可以动态升级连接池。Cowboy就是使用的ranch。

https://github.com/ninenines/ranch

下面通过改造ranch自带的reverse example实现简易的服务端。

game_server.app.src

[plain] view plain copy

{application, game_server, [
{description, "Ranch TCP reverse example."},
{vsn, "1"},
{modules, []},
{registered, []},
{applications, [
kernel,
stdlib,
ranch
]},
{mod, {game_server_app, []}},
{env, []}
]}.

game_server_app.erl

[plain] view plain copy

-module(game_server_app).
-behaviour(application).
-export([start/2, stop/1]).
%% start/2
start(_Type, _StartArgs) ->
{ok, _Pid} = ranch:start_listener(tcp_reverse, 1,
ranch_tcp, [{port, 5555},{max_connections, 10240}], game_protocol, []),
game_server_sup:start_link().
%% stop/1
stop(State) ->
ok.

这里注意ranch:start_listener(Ref, NbAcceptors, Transport, TransOpts, Protocol, ProtoOpts) -> {ok, pid()} | {error, badarg}.

最大连接数max_connections就是在这里进行设定，默认值1024. NbAcceptors， Acceptor的数量，具体数值要根据实际并发设置。

Ranch接受请求并建立连接，然后就会将具体的处理交给实现了ranch_protocol行为的game_protocol，erlang中的behaviour跟java中的接口差不多。

game_server_sup.erl

[plain] view plain copy

-module(game_server_sup).
-behaviour(supervisor).
-export([start_link/0, init/1]).
-spec start_link() -> {ok, pid()}.
start_link() ->
supervisor:start_link({local, ?MODULE}, ?MODULE, []).
%% init/1
init([]) ->
{ok, {{one_for_one, 10, 10}, []}}.

game_protocol.erl

[plain] view plain copy

-module(game_protocol).
-behaviour(gen_server).
-behaviour(ranch_protocol).
%% API.
-export([start_link/4]).
%% gen_server.
-export([init/4]).
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]).
-define(TIMEOUT, 50000).
-record(state, {socket, transport}).
%% API.
start_link(Ref, Socket, Transport, Opts) ->
proc_lib:start_link(?MODULE, init, [Ref, Socket, Transport, Opts]).
%% gen_server.
%% This function is never called. We only define it so that
%% we can use the -behaviour(gen_server) attribute.
init([]) -> {ok, undefined}.
init(Ref, Socket, Transport, _Opts = []) ->
ok = proc_lib:init_ack({ok, self()}),
ok = ranch:accept_ack(Ref),
ok = Transport:setopts(Socket, [{active, once}, {packet, 2}]),
gen_server:enter_loop(?MODULE, [],
#state{socket=Socket, transport=Transport},
?TIMEOUT).
handle_info({tcp, Socket, Data}, State=#state{
socket=Socket, transport=Transport}) ->
io:format("Data:~p~n", [Data]),
Transport:setopts(Socket, [{active, once}]),
Transport:send(Socket, reverse_binary(Data)),
{noreply, State, ?TIMEOUT};
handle_info({tcp_closed, _Socket}, State) ->
{stop, normal, State};
handle_info({tcp_error, _, Reason}, State) ->
{stop, Reason, State};
handle_info(timeout, State) ->
{stop, normal, State};
handle_info(_Info, State) ->
{stop, normal, State}.
handle_call(_Request, _From, State) ->
{reply, ok, State}.
handle_cast(_Msg, State) ->
{noreply, State}.
terminate(_Reason, _State) ->
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.
%% Internal.
reverse_binary(B) when is_binary(B) ->
list_to_binary(lists:reverse(binary_to_list(B))).

这里init的实现与常规的gen_server不一样。首先来说为什么不能用常规的gen_server写法。常规写法如下：

[plain] view plain copy

init([Ref, Socket, Transport, Opts]) ->
ok = ranch:accept_ack(Ref),
ok = Transport:setopts(Socket, [{active, once}, {packet, 2}]),
{ok, #state{socket=Socket, transport=Transport}}.

gen_server的start_link只有在init/1执行完毕后才会返回，但我们来看ranch:accept_ack(Ref):

[plain] view plain copy

-spec accept_ack(ref()) -> ok.
accept_ack(Ref) ->
receive {shoot, Ref, Transport, Socket, AckTimeout} ->
Transport:accept_ack(Socket, AckTimeout)
end.

运行ranch:accept_ack/1时，进程会阻塞，等待{shoot, ...}这条消息，直到接收到此消息才会继续执行，接着才会完成init。但是{shoot, ...}这条消息从哪里来？查下ranch源码不难发现，ranch在建立了与新的gen_server进程的连接后，会向gen_server进程发送该消息(参考ranch_conns_sup:loop/4). 显然，gen_server进程在等待ranch:accept_ack接收到{shoot,...}消息迟迟不能返回，而ranch又无法与gen_server进程连接发送不了{shoot, ...}消息，造成死锁。故使用proc_lib:start_link/3优雅地解决了此问题。

下面copy一下文档的一个说明：

By default the socket will be set to return `binary` data, with the
options `{active, false}`, `{packet, raw}`, `{reuseaddr, true}` set.
These values can't be overriden when starting the listener, but
they can be overriden using `Transport:setopts/2` in the protocol.

It will also set `{backlog, 1024}` and `{nodelay, true}`, which
can be overriden at listener startup.

这也就是为什么{active, once}, {packet, 2}只能在procotol里重写

这样就实现了一个基本的服务端，make后编写脚本启动：

start.sh

[plain] view plain copy

erl -pa ebin deps/*/ebin +K true +P 199999 \
-sname game_server \
-s game

-s game表示启动时默认调用game:start/0方法。

game.erl

[plain] view plain copy

-module(game).
%% ====================================================================
%% API functions
%% ====================================================================
-export([start/0, stop/0]).
start() ->
ok = application:start(ranch),
ok = application:start(game_server).
stop() ->
application:stop(ranch),
application:stop(game_server).

如果设置{packet, raw}的话，直接打开一个Terminal $ telnet localhost 5555 就可以进行测试了。

不过这里设置的{packet,2}，所以写了个测试client发送消息，建立连接->发送消息->接收返回消息->关闭连接：

[plain] view plain copy

-module(client).
-export([send/1]).
send(BinMsg) ->
SomeHostInNet = "localhost",
{ok, Sock} = gen_tcp:connect(SomeHostInNet, 5555,
[binary, {packet, 2}]),
ok = gen_tcp:send(Sock, BinMsg),
receive
{tcp,Socket,String} ->
io:format("Client received = ~p~n",[String]),
gen_tcp:close(Socket)
after 60000 ->
exit
end,
ok = gen_tcp:close(Sock).

handler_info中加入不同消息的处理，就可以时间一个简单的游戏服务器了。R17后可以使用{active, N}，程序效率应该会更高。

release和项目下载见： http://blog.csdn.net/huang1196/article/details/41010127

使用erlang ranch tcp开发服务端相关推荐

易语言tcp多线程服务端客户端_从TCP协议到TCP通信的各种异常现象和分析
很多人总觉得学习TCP/IP协议没什么用,觉得日常编程开发只需要知道socket接口怎么用就可以了.如果大家定位过线上问题就会知道,实际上并非如此.如果应用在局域网内,且设备一切正常的情况下可能确实如 ...
TCP/IP网络编程之基于TCP的服务端/客户端（二）
回声客户端问题上一章TCP/IP网络编程之基于TCP的服务端/客户端(一)中,我们解释了回声客户端所存在的问题,那么单单是客户端的问题,服务端没有任何问题?是的,服务端没有问题,现在先让我们回顾下服 ...
TCP/IP网络编程之基于TCP的服务端/客户端（一）
TCP/IP网络编程之基于TCP的服务端/客户端(一) 理解TCP和UDP 根据数据传输方式的不同,基于网络协议的套接字一般分为TCP套接字和UDP套接字.因为TCP套接字是面向连接的,因此又称为基于 ...
java贪吃蛇客户端服务器_java Socket套接字TCP编程开发服务端和客户端之间的通信 - 贪吃蛇学院-专业IT技术平台...
超级简单,没有太多实质内容的Socket服务端,客户端小程序先运行server 再运行client OK 服务端代码如下: public class Server { public static v ...
QT网络编程开发服务端
下一篇: QT网络编程开发客户端文章目录基于Qt的网络编程服务端 QTcpServer 配置 listen() close() newConnection() SINGL readyRead() ...
C#创建TCP/IP服务端和客户端，含测试demo及源码
网上的TCP/IP创建服务端和客户端的方法鱼龙混杂,自己把在使用项目中的TCP服务端和客户端的代码抽了出来,做了demo,以供大家使用参考. 为了方便调用,我把一些基础方法都整合封装到了Reader. ...
从编程小白到全栈开发：基于框架开发服务端
上文中,我们了解了关于服务器端的一些概念知识,尤其是HTTP协议相关的最基本知识点,今天我想跟大家分享一下在平时正真的开发中,是如何来利用和体现这些内容的. 还记得我在<从编程小白到全栈开发:改 ...
java批量生成订单号_【笔记6-支付及订单模块】从0开始独立完成企业级Java电商网站开发(服务端)...
支付模块实际开发工作中经常会遇见如下场景,一个支付模块,一个订单模块,有一定依赖,一个同事负责支付模块,另一个同事负责订单模块,但是开发支付模块的时候要依赖订单模块的相关类 ,方法,或者工具类,这些 ...
基于 IOCP 的通用异步 Windows Socket TCP 高性能服务端组件的设计与实现
设计概述服务端通信组件的设计是一项非常严谨的工作,其中性能.伸缩性和稳定性是必须考虑的硬性质量指标,若要把组件设计为通用组件提供给多种已知或未知的上层应用使用,则设计的难度更会大大增加,通用性.可用 ...

使用erlang ranch tcp开发服务端

使用erlang ranch tcp开发服务端相关推荐

最新文章

热门文章