erlang获取一个5900——65535之间不重复的一个数据

2024-02-17 03:58
文章标签 数据 重复 获取 之间 65535 erlang 5900

本文主要是介绍erlang获取一个5900——65535之间不重复的一个数据，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

有这样一个问题，我们要获取一个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一个进程，这个是可以的，但是我不知道使用是不是一件好的事情。
<script>window._bd_share_config={"common":{"bdSnsKey":{},"bdText":"","bdMini":"2","bdMiniList":false,"bdPic":"","bdStyle":"0","bdSize":"16"},"share":{}};with(document)0[(getElementsByTagName('head')[0]||body).appendChild(createElement('script')).src='http://bdimg.share.baidu.com/static/api/js/share.js?v=89860593.js?cdnversion='+~(-new Date()/36e5)];</script>
阅读(676) | 评论(0) | 转发(0) |
0

上一篇：erlang 进制转换

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

相关热门文章
  • python 自动化测试平台 Robot ...
  • python 自动化测试平台 Robot ...
  • python snmp 自动化2-在python...
  • 自动化测试详细测试计划 模板...
  • python snmp 自动化3-修改pyth...
  • linux dhcp peizhi roc
  • 关于Unix文件的软链接
  • 求教这个命令什么意思，我是新...
  • sed -e "/grep/d" 是什么意思...
  • 谁能够帮我解决LINUX 2.6 10...
给主人留下些什么吧！~~
评论热议

这篇关于erlang获取一个5900——65535之间不重复的一个数据的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/716603。

相关文章

如何利用Java获取当天的开始和结束时间

如何利用Java获取当天的开始和结束时间

《如何利用Java获取当天的开始和结束时间》：本文主要介绍如何使用Java8的LocalDate和LocalDateTime类获取指定日期的开始和结束时间,展示了如何通过这些类进行日期和时间的处... 目录前言1. Java日期时间API概述2. 获取当天的开始和结束时间代码解析运行结果3. 总结前言在J
阅读更多...
java父子线程之间实现共享传递数据

java父子线程之间实现共享传递数据

《java父子线程之间实现共享传递数据》本文介绍了Java中父子线程间共享传递数据的几种方法,包括ThreadLocal变量、并发集合和内存队列或消息队列,并提醒注意并发安全问题... 目录通过 ThreadLocal 变量共享数据通过并发集合共享数据通过内存队列或消息队列共享数据注意并发安全问题总结在 J
阅读更多...
Redis的数据过期策略和数据淘汰策略

Redis的数据过期策略和数据淘汰策略

《Redis的数据过期策略和数据淘汰策略》本文主要介绍了Redis的数据过期策略和数据淘汰策略,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录一、数据过期策略1、惰性删除2、定期删除二、数据淘汰策略1、数据淘汰策略概念2、8种数据淘汰策略
阅读更多...
轻松上手MYSQL之JSON函数实现高效数据查询与操作

轻松上手MYSQL之JSON函数实现高效数据查询与操作

《轻松上手MYSQL之JSON函数实现高效数据查询与操作》：本文主要介绍轻松上手MYSQL之JSON函数实现高效数据查询与操作的相关资料,MySQL提供了多个JSON函数,用于处理和查询JSON数... 目录一、jsON_EXTRACT 提取指定数据二、JSON_UNQUOTE 取消双引号三、JSON_KE
阅读更多...
Java文件与Base64之间的转化方式

Java文件与Base64之间的转化方式

《Java文件与Base64之间的转化方式》这篇文章介绍了如何使用Java将文件（如图片、视频）转换为Base64编码,以及如何将Base64编码转换回文件,通过提供具体的工具类实现,作者希望帮助读者... 目录Java文件与Base64之间的转化1、文件转Base64工具类2、Base64转文件工具类3、
阅读更多...
java获取图片的大小、宽度、高度方式

java获取图片的大小、宽度、高度方式

《java获取图片的大小、宽度、高度方式》文章介绍了如何将File对象转换为MultipartFile对象的过程,并分享了个人经验,希望能为读者提供参考... 目China编程录Java获取图片的大小、宽度、高度File对象（该对象里面是图片）MultipartFile对象（该对象里面是图片）总结java获取图片
阅读更多...
Java通过反射获取方法参数名的方式小结

Java通过反射获取方法参数名的方式小结

《Java通过反射获取方法参数名的方式小结》这篇文章主要为大家详细介绍了Java如何通过反射获取方法参数名的方式,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1、前言2、解决方式方式2.1： 添加编译参数配置 -parameters方式2.2： 使用Spring的内部工具类 -
阅读更多...
Java如何获取视频文件的视频时长

Java如何获取视频文件的视频时长

《Java如何获取视频文件的视频时长》文章介绍了如何使用Java获取视频文件的视频时长,包括导入maven依赖和代码案例,同时,也讨论了在运行过程中遇到的SLF4J加载问题,并给出了解决方案... 目录Java获取视频文件的视频时长1、导入maven依赖2、代码案例3、SLF4J: Failed to lo
阅读更多...
Python给Excel写入数据的四种方法小结

Python给Excel写入数据的四种方法小结

《Python给Excel写入数据的四种方法小结》本文主要介绍了Python给Excel写入数据的四种方法小结,包含openpyxl库、xlsxwriter库、pandas库和win32com库,具有... 目录1. 使用 openpyxl 库2. 使用 xlsxwriter 库3. 使用 pandas 库
阅读更多...
SpringBoot定制JSON响应数据的实现

SpringBoot定制JSON响应数据的实现

《SpringBoot定制JSON响应数据的实现》本文主要介绍了SpringBoot定制JSON响应数据的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们... 目录前言一、如何使用@jsonView这个注解？二、应用场景三、实战案例注解方式编程方式总结 前言
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2