Chinaunix首页 | 论坛 | 博客

飞着【FLYING】sunjiangang.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

sunjiangang-ok

  • 博客访问： 1901740
  • 博文数量： 217
  • 博客积分： 4362
  • 博客等级： 上校
  • 技术积分： 4180
  • 用 户 组： 普通用户
  • 注册时间： 2009-09-20 09:31
文章分类

全部博文（217）

文章存档

2017年（1）

2015年（2）

2014年（2）

2013年（6）

2012年（42）

2011年（119）

2010年（28）

2009年（17）

我的朋友
最近访客
推荐博文
相关博文
erlang获取一个5900——65535之间不重复的一个数据

分类： Python/Ruby

2011-08-04 16:11:08

    有这样一个问题，我们要获取一个5900～65535之间的一个端口号。对于这个端口号必须是唯一出现的，不能重复，如果分配出去的端口号使用完了之后，还要进行相应的回收，等待下一次的分配。要使用erlang来实现，这个该如何实现呢？
    我是这么来实现的，在我的实现当中要使用mnesia数据库。每分配一个端口号出去之后，就将分配的端口号记录在数据库中，并且在数据库中使用一项记录下一次可以分配并且使用的端口号的值。如果下一次请求分配的时候，就直接读取分配出去的那个端口号，然后更新这一项，往数据库中添加已经分配的这个端口号，等下一次如果再次分配的时候，就直接分配。
    我的程序代码如下：
  1. %% vncport.erl
  2. %% Author: Sunny
  3. %% Created: 2011-7-25
  4. %% Description: get vncport
  5. -module(vncport).
  6. -date("2011.07.25").

  8. %%
  9. %% Include Files
  10. %%
  11. -include_lib("stdlib/include/qlc.hrl").
  12. -record(vnc_counter,
  13.                 {
  14.                 vncport_num,
  15.                 used_flag
  16.                 }).

  18. %%
  19. %% Exported Functions
  20. %%
  21. -export([init/0, stop/0]).
  22. -export([recovery_one_vncport/1]).
  23. -export([get_next_vncport/0]).

  25. %%
  26. %% Api Functions
  27. %%
  28. init() ->
  29.      mnesia:stop(),
  30.      mnesia:delete_schema([node()]),
  31.      mnesia:create_schema([node()]),
  32.      mnesia:start(),
  33.      mnesia:create_table(vnc_counter,[{attributes, record_info(fields, vnc_counter)}]),
  34.      F = fun(N) ->
  35.              insert_to_table(N)
  36.          end,
  37.      for(5908, 5910, F),
  38.      for(5915, 5917, F),
  39.      mnesia:dirty_update_counter(vnc_counter, mac_id, 5900).

  41. stop() ->
  42.     mnesia:stop().

  44. get_next_vncport() ->
  45.     Query = qlc:q([X#vnc_counter.used_flag || X <- mnesia:table(vnc_counter),
  46.                     X#vnc_counter.vncport_num =:= mac_id]),
  47.     F = fun() ->
  48.             qlc:e(Query)
  49.     end,
  50.     io:format("get the vncport which is not used~n"), %% degug info
  51.     {atomic, [Result]} = mnesia:transaction(F),
  52. %    spawn(fun() -> update_vnc_counter(Result) end),
  53.     update_vnc_counter(Result),
  54.     io:format("get the next vncport is:~p~n", [Result]), %% debug info
  55.     Result.

  57. recovery_one_vncport(N) ->
  58.     Row = {vnc_counter, N},
  59.     F = fun() ->
  60.         mnesia:delete(Row)
  61.     end,
  62.     Result = mnesia:transaction(F),
  63.     io:format("delete ~p successfully~n", [N]), %% debug info
  64.     Result.

  66. %%
  67. %% Local Functions
  68. %%
  69. update_vnc_counter(X) ->
  70.     io:format("spawn one process to update vnc_counter~n"), %% debug info
  71.     insert_to_table(X),
  72.     io:format("add one used vncport to vnc_counter successfully!~n"), %% debug info
  73.     if
  74.         X+1 > 65535 ->
  75.             N=5900;
  76.         X+1 =< 65535 ->
  77.             N=X+1
  78.     end,
  79.     io:format("now begin check whether in vnc_counter~n"), %% debug info
  80.     case check_in_vnc_counter(N) of
  81.         true ->
  82.             io:format("find ~p is in vnc_counter~n", [N]), %% debug info
  83.             NX = find_not_in_vnc_counter(N), %% find one not in vnc_counter
  84.             Row = #vnc_counter{vncport_num=mac_id, used_flag=NX};
  85.         false ->
  86.             io:format("find ~p is not in vnc_counter~n", [N]), %% debug info
  87.             Row = #vnc_counter{vncport_num=mac_id, used_flag=N}
  88.     end,
  89.     F = fun() ->
  90.             mnesia:write(Row)
  91.         end,
  92.     mnesia:transaction(F),
  93.     io:format("update vnc_counter over~n"), %% debug info
  94.     ok.

  96. check_in_vnc_counter(N) ->
  97.     io:format("check ~p is or not in vnc_counter~n", [N]), %% debug info
  98.     Query = qlc:q([X#vnc_counter.vncport_num || X <- mnesia:table(vnc_counter),
  99.                     X#vnc_counter.vncport_num =:= N]),
  100.     F = fun() ->
  101.             qlc:e(Query)
  102.     end,
  103.     Result = mnesia:transaction(F),
  104.     io:format("check result is:~p~n", [Result]), %% debug info
  105.     case Result of
  106.         {atomic, []} ->
  107.             Return = false;
  108.         {atomic, [_]} ->
  109.             Return = true
  110.     end,
  111.     Return.

  113. find_not_in_vnc_counter(N) ->
  114.     if
  115.         N+1 > 65535 ->
  116.             NX = 5900;
  117.         N+1 =< 65535 ->
  118.             NX = N+1
  119.     end,
  120.     case check_in_vnc_counter(NX) of
  121.         true ->
  122.             Result = find_not_in_vnc_counter(N+1);
  123.         false ->
  124.             Result = NX
  125.     end,
  126.     Result.

  128. insert_to_table(N) ->
  129.     Row = #vnc_counter{vncport_num=N, used_flag=yes},
  130.     F = fun() ->
  131.             mnesia:write(Row)
  132.         end,
  133.     mnesia:transaction(F).

  135. for(Max, Max, F) ->
  136.     [F(Max)];
  137. for(Min, Max, F) ->
  138.     [F(Min)|for(Min+1, Max, F)].
    这个程序的执行结果是：
  1. 1> c(vncport).
  2. {ok,vncport}
  3. 2> vncport:init().
  4. 5900
  5. 3> vncport:get_next_vncport().
  6. get the vncport which is not used
  7. spawn one process to update vnc_counter
  8. add one used vncport to vnc_counter
  9. now begin check whether in vnc_counter
  10. check 5901 is or not in vnc_counter
  11. check result is:{atomic,[]}
  12. find 5901 is not in vnc_counter
  13. update vnc_counter over
  14. get the next vncport is:5900
  15. 5900
  16. 4> vncport:get_next_vncport().
  17. get the vncport which is not used
  18. spawn one process to update vnc_counter
  19. add one used vncport to vnc_counter
  20. now begin check whether in vnc_counter
  21. check 5902 is or not in vnc_counter
  22. check result is:{atomic,[5902]}
  23. find 5902 is in vnc_counter
  24. check 5903 is or not in vnc_counter
  25. check result is:{atomic,[5903]}
  26. check 5904 is or not in vnc_counter
  27. check result is:{atomic,[5904]}
  28. check 5905 is or not in vnc_counter
  29. check result is:{atomic,[5905]}
  30. check 5906 is or not in vnc_counter
  31. check result is:{atomic,[5906]}
  32. check 5907 is or not in vnc_counter
  33. check result is:{atomic,[5907]}
  34. check 5908 is or not in vnc_counter
  35. check result is:{atomic,[5908]}
  36. check 5909 is or not in vnc_counter
  37. check result is:{atomic,[5909]}
  38. check 5910 is or not in vnc_counter
  39. check result is:{atomic,[5910]}
  40. check 5911 is or not in vnc_counter
  41. check result is:{atomic,[]}
  42. update vnc_counter over
  43. get the next vncport is:5901
  44. 5901
  45. 5> vncport:get_next_vncport().
  46. get the vncport which is not used
  47. spawn one process to update vnc_counter
  48. add one used vncport to vnc_counter
  49. now begin check whether in vnc_counter
  50. check 5912 is or not in vnc_counter
  51. check result is:{atomic,[]}
  52. find 5912 is not in vnc_counter
  53. update vnc_counter over
  54. get the next vncport is:5911
  55. 5911
  56. 6> vncport:get_next_vncport().
  57. get the vncport which is not used
  58. spawn one process to update vnc_counter
  59. add one used vncport to vnc_counter
  60. now begin check whether in vnc_counter
  61. check 5913 is or not in vnc_counter
  62. check result is:{atomic,[5913]}
  63. find 5913 is in vnc_counter
  64. check 5914 is or not in vnc_counter
  65. check result is:{atomic,[5914]}
  66. check 5915 is or not in vnc_counter
  67. check result is:{atomic,[5915]}
  68. check 5916 is or not in vnc_counter
  69. check result is:{atomic,[5916]}
  70. check 5917 is or not in vnc_counter
  71. check result is:{atomic,[5917]}
  72. check 5918 is or not in vnc_counter
  73. check result is:{atomic,[]}
  74. update vnc_counter over
  75. get the next vncport is:5912
  76. 5912
  77. 7> vncport:get_next_vncport().
  78. get the vncport which is not used
  79. spawn one process to update vnc_counter
  80. add one used vncport to vnc_counter
  81. now begin check whether in vnc_counter
  82. check 5919 is or not in vnc_counter
  83. check result is:{atomic,[]}
  84. find 5919 is not in vnc_counter
  85. update vnc_counter over
  86. get the next vncport is:5918
  87. 5918
  88. 8> vncport:get_next_vncport().
  89. get the vncport which is not used
  90. spawn one process to update vnc_counter
  91. add one used vncport to vnc_counter
  92. now begin check whether in vnc_counter
  93. check 5920 is or not in vnc_counter
  94. check result is:{atomic,[]}
  95. find 5920 is not in vnc_counter
  96. update vnc_counter over
  97. get the next vncport is:5919
  98. 5919
  99. 9> vncport:get_next_vncport().
  100. get the vncport which is not used
  101. spawn one process to update vnc_counter
  102. add one used vncport to vnc_counter
  103. now begin check whether in vnc_counter
  104. check 5921 is or not in vnc_counter
  105. check result is:{atomic,[]}
  106. find 5921 is not in vnc_counter
  107. update vnc_counter over
  108. get the next vncport is:5920
  109. 5920
  110. 10>
    可能输出的信息比较多些，但是对于本程序来说我们只要关注最后的那个数据就行了。
    在我的程序中有一个小的技巧就是在init()函数中使用的
    mnesia:dirty_update_counter(vnc_counter, mac_id, 5900)，
    我使用了这个来记录下一次要读取的可以使用的数据，原先使用文件的记录，发现那是有问题的，而且在程序中处理数据库可以使用spawn一个进程，这个是可以的，但是我不知道使用是不是一件好的事情。
阅读(1200) | 评论(0) | 转发(0) |
0

上一篇：erlang 进制转换

下一篇：标准I/O的三种缓冲

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6