没有开花的树 Blog

原文 2014-06-16 23:19:36 发表于 CSDN，这里对以前写的文章做下收录。

erlang有两种复合结构，tuple和list，两者的区别是tuple子元素的个数是固定不变的，声明后就不能改变了；而list是可变的，可以通过[H|T]来取出或插入新元素。record有点像C/C++里面的结构体，实际上是语法糖，方便我们的开发，代码汇编时转成tuple表达形式。

Tuple
tuple的表示方法如：
{Term1,...,TermN}

下面以例子说明erlang tuple及一些基本操作：

1> A = {1,2}.
{1,2}
2> tuple_size(A).
2
3> is_tuple(A).
true
4> tuple_to_list(A).
[1,2]
5> element(1, A).
1
6> setelement(2, A, 3).
{1,3}

Record
record有点像C/C++里面的结构体，表示方法如：

-record(Name, {Field1 [= Value1],
               ...
               FieldN [= ValueN]}).

继续阅读erlang tuple 和 record

原文 2013-09-11 20:28:16 发表于 CSDN，这里对以前写的文章做下收录。

Erlang的位语法（Erlang Bit Syntax）提供了一种方法来表示和匹配二进制数据，这使得Erlang二进制对象在某种程度上等同于其他Erlang对象，如元组和列表。也因为其快速高效，使得在Erlang中，二进制对象被广泛使用，尤其是在协议编程方面。（官方文档）

位语法/比特语法（bit syntax）
Erlang的位语法表达式，即Erlang二进制的表示形式：
<<>>
<<E1,...,En>>

每个元素Ei指定了一段二进制串（bit string）。每个元素Ei都是一个值，后面可以带有可选参数Size、TypeSpecifierList，如下：
Ei = Value |
Value:Size |
Value/TypeSpecifierList |
Value:Size/TypeSpecifierList
继续阅读erlang 二进制与位语法

原文 2014-05-29 22:58:26 发表于 CSDN，这里对以前写的文章做下收录。

看了erlang的一些开源网络框架RabbitMQ、Ranch，他们都使用多个进程同时accept一个socket。这种方式在使得socket端口监听的工作分担了更多的调度机会，但是，在erlang中，socket接受一个新连接后，如果想让另一个进程处理消息，就要显式的调用gen_tcp:controlling_process(Socket, Pid)。

所以问题来了，erlang多个进程同时监听一个socket安全吗？
这种方式在早期的erlang是不安全的，但R11B03 版本之后，erlang做了改进，允许多个进程同时监听同一个socket。

erlang R11B03 更新日志
OTP-6416 gen_tcp now allows for several processes to issue accept calls to the same listen-socket simultaniously. The different accepting processes will get connected sockets on a first-come-first-served basis.

当多个进程同时accept一个socket，erlang 内部将使用队列保存acceptor信息，以先来先服务的原则将新的连接关联到acceptor，再给acceptor投递消息 {inet_async, L, Ref, Result}。
具体看\erts\emulator\drivers\common\inet_drv.c 的 tcp_inet_ctl 函数，erlang对socket的处理都集中在inet_drv.c

erlang配合{backlog, N}，监听新连接效果更佳
backlog是erlang用来设置socket等待连接队列。N为队列的长度，默认值5，显然太小了

原文 2015-01-12 00:11:27 发表于 CSDN，这里对以前写的文章做下收录。

erlang 提供 binary_to_term，把一个二进制数据转为原始的 erlang 数据。但是，这个函数也有副作用。如果直接将对端传来的数据做一次 binary_to_term，就有可能导致VM crash掉。

binary_to_term 副作用
这是因为二进制数据带有原子时，binary_to_term 会生成这些原子。但VM原子总数是有限制，而且原子不参与GC。假如数据带有原子数量超过erlang VM限制，就会导致VM crash
所以，针对这个问题，erlang提供了另外一个函数 binary_to_term(Binary, [safe])，这个函数不会生成新的的原子，在这点上，这两个函数关系也像 list_to_atom 和 list_to_existing_atom

1> term_to_binary(atom).
<<131,100,0,4,97,116,111,109>>
2> binary_to_term(v(1), [safe]).
atom
3> binary_to_term(v(1)).
atom
4> binary_to_term(<<131,100,0,4,116,101,115,116>>, [safe]).
%%这里会抛出异常
** exception error: bad argument
     in function  binary_to_term/2
        called as binary_to_term(<<131,100,0,4,116,101,115,116>>,[safe])
5> binary_to_term(<<131,100,0,4,116,101,115,116>>).
test
6> binary_to_term(<<131,100,0,4,116,101,115,116>>, [safe]).
%%这里就不会抛出异常
test

继续阅读erlang binary 数据转换问题

原文 2014-06-10 01:01:57 发表于 CSDN，这里对以前写的文章做下收录。

erlang 二进制数据在内存中有两种存在形式，当数据大小不到 64 bytes，就直接存在进程堆内，如果超过了 64 bytes，就被保存到进程外的共享堆里，可以给节点内所有进程共享。

erlang 有两种二进制容器：heap binaries 和 refc binaries。
heap binaries

Heap binaries are small binaries, up to 64 bytes, that are stored directly on the process heap. They will be copied when the process is garbage collected and when they are sent as a message. They don't require any special handling by the garbage collector.

这个就是进程堆二进制，是一些比较小的二进制数据，每个数据大小不超过 64bytes，这些数据保存在进程堆内。对于这里的二进制数据，垃圾回收走的是进程堆数据的回收机制，参考这里。如果发给其他进程的消息含有这些数据，erlang 将直接复制一份到别的进程堆内。
继续阅读erlang二进制数据垃圾回收