Erlang经常使用代码段

• 十六进制字符串转为二进制

  hex_to_bin(Bin) ->  
      hex2bin(Bin).
  
  hex2bin(Bin) when is_binary(Bin) ->
      hex2bin(binary_to_list(Bin));
  hex2bin([]) ->
      <<>>;
  hex2bin([X, Y | Rest]) ->
      <<(erlang:list_to_integer([X], 16) * 16 + erlang:list_to_integer([Y], 16)):8, (hex2bin(Rest))/binary>>.

• 二进制转为十六进制字符串

  bin2hex(B) ->
      bin2hex(B, lower).
  
  bin2hex(B, LowerOrUpper) when is_binary(B) ->
      bin2hex(binary_to_list(B), LowerOrUpper);
  bin2hex(L, upper) ->
      LH0 = lists:map(fun(X) -> erlang:integer_to_list(X, 16) end, L),
      LH = lists:map(fun([X, Y]) -> [X, Y]; ([X]) -> [$0, X] end, LH0),
      lists:flatten(LH);
  bin2hex(B, lower) ->
      H = bin2hex(B, upper),
      string:to_lower(H).

• 反编译代码
  有时候线上出问题的时候，须要查看线上运行的代码，这时候就用到反编译了。

decompile(Mod) ->
    {ok, {_, [{abstract_code, {_, AC}}]}} = beam_lib:chunks(code:which(Mod), [abstract_code]),
    try
        io:format("~s~n", [erl_prettypr:format(erl_syntax:form_list(AC))])
    catch
        io:format("~ts~n", [erl_prettypr:format(erl_syntax:form_list(AC))])
    end.

• 分裂进程
  erlang分裂进程的函数是erlang:spawn。选项有

  spawn(Fun) -> pid()
  spawn(Node, Fun) -> pid() %若是Node不存在，返回一个无用的pid
  spawn(Module, Function, Args) -> pid()
  spawn(Node, Module, Function, Args) -> pid()
  spawn_link(Fun) -> pid()
  spawn_link(Node, Fun) -> pid()
  spawn_link(Module, Function, Args) -> pid()
  spawn_link(Node, Module, Function, Args) -> pid()
  spawn_monitor(Fun) -> {pid(), reference()}
  spawn_monitor(Module, Function, Args) -> {pid(), reference()}
  spawn_opt(Fun, Options) -> pid() | {pid(), reference()}
  spawn_opt(Node, Fun, Options) -> pid() | {pid(), reference()}
  spawn_opt(Module, Function, Args, Options) -> pid() | {pid(), reference()}
  spawn_opt(Node, Module, Function, Args, Options) -> pid() | {pid(), reference()}
  Options = [Option]
  Option = 
      link |
      monitor | 
      {priority, Level :: priority_level()} |
      {fullsweep_after, Number :: integer() >= 0} |
      {min_heap_size, Size :: integer() >= 0} |
      {min_bin_vheap_size, VSize :: integer() >= 0}
      priority_level() = low | normal | high | max

  • link: 父进程与子进程创建链接
  • monitor: 父进程监控子进程
  • {priority, Level}: 设置新的进程的优先级。等价于在新进程中执行process_flag(priority, Level)。区别在于，spawn的时候设置优先级，优先级会在进程被选择运行以前就设置好了。
  • {fullsweep_after, Number}：只是用在调整性能上。Erlang的运行系统，使用的是分代的垃圾回收机制。用一个『old heap』保存至少存活了一个垃圾回收周期的数据，当old heap空间不够时，就会执行垃圾回收。
  • {min_heap_size, Size}，只是用在调整性能上。设置heap的最小size，单位是word。将这个值设置的比系统默认的大的话，会加速一些进程运行，由于会减小垃圾回收的执行次数。可是太大会致使内存不够，减慢系统运行。
  • {min_bin_vheap_size, VSize},只是用在调整性能上。

• 交叉引用工具：xref。xref经过分析函数的调用和定义，发现函数、模块、应用和版本之间的依赖关系。这个工具能够帮助查看是否有函数名输入错误。在用rebar打包时，能够用rebar xref执行。

• 得到ps命令获得的消耗的内存

  get_ps_real_memory() ->
      Cmd = "pid=`echo $$`;p=`ps -ef | awk -v pid=$pid '$2 == pid {print $3}'`;mem=`ps -o rss -p $p | grep -v RSS`;r=$(($mem/1024));echo $r",
      os:cmd(Cmd),
      Result = os:cmd(Cmd),
      string:substr(Result, 1, length(Result) - 1).

• 得到top命令获得的消耗的内存

  get_top_real_memory() ->
      Cmd = "pid=`echo $$`;p=`ps -ef | awk -v pid=$pid '$2 == pid {print $3}'`;mem=`cat /proc/$p/stat | awk '{print $24}'`;r=$(($mem*4096/1024/1024));echo $r",
      Result = os:cmd(Cmd),
      case length(Result) > 1 of
          true ->
              string:substr(Result, 1, length(Result) -1);
          false ->
              0
      end.

• 得到当前cpu的核数

  get_cpu_count() ->
      Cmd = "cat /proc/cpuinfo | grep processor | wc -l",
      R = os:cmd(Cmd),
      case string:to_integer(R) of
          {Count, _} when is_integer(Count) -> Count;
          {error, _} -> 0
      end.

• 得到ps命令获得的虚拟内存消耗

  get_ps_virtual_memory() ->
      Cmd = "pid=`echo $$`;p=`ps -ef | awk -v pid=$pid '$2 == pid {print $3}'`;mem=`ps -o vsz -p $p | grep -v VSZ`;r=$(($mem/1024));echo $r",
      Result = os:cmd(Cmd),
      string:substr(Result, 1, length(Result) - 1).

+得到top命令获得的虚拟内存消耗

```erlang
get_top_virtual_memory() ->
    Cmd = "pid=`echo $$`;p=`ps -ef | awk -v pid=$pid '$2 == pid {print $3}'`;mem=`cat /proc/$p/stat | awk '{print $24}'`;r=$(($mem*4096/1024/1024));echo $r",
    Result = os:cmd(Cmd),
    case length(Result) > 1 of
        true ->
            string:substr(Result, 1, length(Result) - 1);
        false ->
            0
    end.
```

• 得到erlang运行时的进程信息

process_infos() ->          
    filelib:ensure_dir("./log/"),
    File = "./log/processes_infos.log",
    {ok, Fd} = file:open(File, [write, raw, binary, append]), 
    Fun = fun(Pi) ->
                   Info = io_lib:format("=>~p \n\n",[Pi]),
                  case  filelib:is_file(File) of
                        true   ->   file:write(Fd, Info);
                        false  ->
                            file:close(Fd),
                            {ok, NewFd} = file:open(File, [write, raw, binary, append]),
                            file:write(NewFd, Info)
                     end,
                     timer:sleep(20)
                 end,
    [Fun(erlang:process_info(P)) ||   P <- erlang:processes()].

• eralng gen_server:call

这是一个同步调用，pid1经过erlang:send()发送给pid2消息后，receive等待返回，这时候pid1处于阻塞状态。pid2是一个gen_server行为模式的进程，loop函数接收到消息后，进行相应处理，并返回。

• gen_server:cast

直接用erlang:send发送'$gen_cast'消息。