国际棋牌

 
 加入
国际棋牌»论坛 › au3交流 › 『 提问交流 』 › 无意义问题区 › 如何 用tcp实现远程关机、重启
12下一页
返回列表
查看: 400|回复: 18

如何 用tcp实现远程关机、重启-国际棋牌

[复制链接]
wllx
发表于 2023-10-5 10:09:08 | 显示全部楼层 |
如何 用tcp实现远程关机、重启
发表于 2023-10-5 14:48:46 | 显示全部楼层
请附上你的思路和代码,否则没人会理你...


===================
wllx
 楼主| 发表于 2023-10-5 16:33:54 | 显示全部楼层
本帖最后由 wllx 于 2023-10-5 17:11 编辑

请附上你的思路和代码,否则没人会理你...


  1. #include
  2. #include
  3. #include
  4. #include
  5. #include
  6. #include
  7. #include
  8. #include
  9. #include
  10. #include
  11. #include
  12. #include
  13. #include
  14. #include
  15. #include
  16. #include
  17. #include
  18. #include
  19. _winapi_wow64enablewow64fsredirection(false)
  20. local $cofing = @scriptdir & "\wim\jydn\lan.ini", $fonts = "微软雅黑"
  21. _skins3()
  22. local $tcpport = 8411, $tcpip = @ipaddress1
  23. local $_tcp_hsockets[1][10], $recvone = 0, $delsocket = -1, $connectedsocket, $recvtcp = 0
  24. local $tcprecvmode, $postsk, $mainstr = "####", $recvbtos, $recvold, $error
  25. local $mainsocket = tcplisten($tcpip, $tcpport)
  26. local $mht = guicreate("远程控制", 326, 500)
  27. local $listview3 = guictrlcreatelistview("", 10, 10, 306, 480)
  28. _guictrllistview_settextbkcolor($listview3, 6027594)
  29. _guictrllistview_addcolumn($listview3, "", 0)
  30. _guictrllistview_addcolumn($listview3, "socket", 0)
  31. _guictrllistview_addcolumn($listview3, "客户端名称", 145, 2)
  32. _guictrllistview_addcolumn($listview3, "客户端ip地址", 145, 2)
  33. $listmenu = guictrlcreatecontextmenu($listview3)
  34. $reboot= guictrlcreatemenuitem("重启客户端", $listmenu)
  35. guictrlsetfont(-1, 9, 400, 1, $fonts)
  36. $boot = guictrlcreatemenuitem("关闭客户端", $listmenu)
  37. guictrlsetfont(-1, 9, 400, 1, $fonts)
  38. $tightvnc= guictrlcreatemenuitem("连接客户端", $listmenu)
  39. guictrlsetfont(-1, 9, 400, 1, $fonts)
  40. guisetstate()
  41. tcpstartup()
  42. local $mainsocket = tcplisten(iniread($cofing, "lan", "tcpip ", ""), $tcpport)
  43. guiregistermsg($wm_command, "wm_notify")
  44. mytcp_server($tcpip, $tcpport)
  45. while 1
  46.         _tcprecv()
  47.         _while()
  48. wend

  50. func _while()
  51.         $nmsg = guigetmsg()
  52.         switch $nmsg
  53.                 case $gui_event_close, $idclose
  54.                         exit
  55.         endswitch
  56. endfunc   ;==>_while

  58. func quit()
  59.         tcpshutdown()
  60.         exit
  61. endfunc   ;==>quit
  62. func wm_notify($hwnd, $imsg, $iwparam, $ilparam)
  63.         local $hwndfrom
  64.         $hwndfrom = $ilparam
  65.         switch $iwparam
  66.                 case $tightvnc
  67.                         $index = controllistview($mht, "", "[class:syslistview32; instance:1]", "getselected", 3)
  68.                         if $index <> "" then
  69.                                 $ip = controllistview($mht, "", "[class:syslistview32; instance:1]", "gettext", $index, 3)
  70.                                 traytip("通知", " " &"正在连接" &"☛"& $ip  , 1, 1)
  71.                                 run(@comspec & " /c " & @scriptdir & "\dysoft\tvnviewer.exe" & " " & $ip, @scriptdir, @sw_hide)
  72.                         endif
  73.                         return true
  74.                 case $reboot
  75.                           $index = controllistview($mht, "", "[class:syslistview32; instance:1]", "getselected", 3)
  76.                              if $index <> "" then
  77.                                 $ip = controllistview($mht, "", "[class:syslistview32; instance:1]", "gettext", $index, 3)
  78.                                 traytip("通知", " " &"正在重启" &"☛"& $ip  , 1, 1)
  79.                                 run(@comspec & ' /c ' & 'shutdown -m \\' & $ip & ' -r -f -t 0', '@scriptdi', @sw_hide)
  80.                         endif
  81.                         return true
  82.         case $boot
  83.                           $index = controllistview($mht, "", "[class:syslistview32; instance:1]", "getselected", 3)
  84.                              if $index <> "" then
  85.                                 $ip = controllistview($mht, "", "[class:syslistview32; instance:1]", "gettext", $index, 3)
  86.                                 traytip("通知", " " &"正在关机" &"☛"& $ip  , 1, 1)
  87.                                 run(@comspec & ' /c ' & 'shutdown -m \\' & $ip & ' -s -f -t 0', '@scriptdi', @sw_hide)
  88.                         endif
  89.                         return true
  90.         endswitch
  91. endfunc   ;==>wm_notify

  93. func mytcp_server($tcpip, $tcpport)
  94.   local $ilistensocket = tcplisten($tcpip, $tcpport , 250)
  95.     local $ierror = 0
  96.     if @error then
  97.         $ierror = @error
  98.         return false
  99.     endif
  100.     local $isocket = 0
  101.     do
  102.         $isocket = tcpaccept($ilistensocket)
  103.         if @error then
  104.             $ierror = @error

  106.             return false
  107.         endif
  108. if guigetmsg() = $gui_event_close then return false
  109.     until $isocket <> -1
  110.     tcpclosesocket($ilistensocket)
  111.     local $sreceived = tcprecv($isocket, 4)
  112.     tcpclosesocket($isocket)
  113. endfunc   ;==>mytcp_server

  115. func _tcprecv()
  116.         local $regsocket = -1, $regip, $rdays
  117.         dim $regsocket = tcpaccept($mainsocket)
  118.         if $regsocket <> -1 then
  119.                 dim $recv_1 = tcprecv($regsocket, 1024 * 1024, 1)
  120.                 if @error then
  121.                         $error = int(@error)
  122.                 endif
  123.                 if $recv_1 <> "" then
  124.                         $checkdata = stringleft($recv_1, 12)
  125.                         if $checkdata = "0x232323232b" then
  126.                                 $regip = sockettoip($regsocket)
  127.                                 $recvbtos = binarytostring($recv_1, 4)
  128.                                 $rdays = stringsplit($recvbtos, " ", 1)
  129.                                 if isarray($rdays) then
  130.                                         if ubound($rdays) > 3 then
  131.                                                 if stringupper($rdays[4]) = stringupper("sendname") then
  132.                                                         _socketact($regsocket, $regip, $rdays[5], "sendname")
  133.                                                         dim $onlinepclist = ""
  134.                                                         for $i = 1 to ubound($_tcp_hsockets) - 1
  135.                                                                 $onlinepclist = $onlinepclist & $_tcp_hsockets[$i][0] & "|" & $_tcp_hsockets[$i][2] & ","
  136.                                                         next
  137.                                                 endif
  138.                                         endif
  139.                                 endif
  140.                         endif
  141.                 endif
  142.         else
  143.                 if (ubound($_tcp_hsockets)) > 1 then
  144.                         for $i = 1 to ubound($_tcp_hsockets) - 1
  145.                                 dim $recv_1 = tcprecv($_tcp_hsockets[$i][0], 1024 * 1024, 1)
  146.                                 if @error then
  147.                                         $error = int(@error)
  148.                                         if $error = 10054 then
  149.                                                 if $_tcp_hsockets[$i][0] <> -1 then
  150.                                                         $delsocket = $_tcp_hsockets[$i][0]
  151.                                                         tcpclosesocket($_tcp_hsockets[$i][0])
  152.                                                 endif
  153.                                         endif
  154.                                 endif
  155.                                 if $recv_1 <> "" then
  156.                                         $postsk = $_tcp_hsockets[$i][0]
  157.                                 endif
  158.                         next
  159.                         if $delsocket <> -1 then
  160.                                 _tcp_server_broadcast($delsocket, "offline")
  161.                         endif
  162.                 endif
  163.         endif
  164. endfunc   ;==>_tcprecv

  166. func _socketact($socketid = -1, $socketip = "", $socketname = "", $mode = "add")
  167.         if $socketid <> -1 and $socketip <> "" and $socketname <> "" then
  168.                 dim $name_and_ip = $socketname & "|" & $socketip
  169.                 dim $so_name_and_ip = _arrayfindall($_tcp_hsockets, $socketid, 0, 0, 0, 0, 0)
  170.                 if isarray($so_name_and_ip) then
  171.                         tcpclosesocket($_tcp_hsockets[$so_name_and_ip[0]][0])
  172.                         $_tcp_hsockets[$so_name_and_ip[0]][0] = $socketid
  173.                         $_tcp_hsockets[$so_name_and_ip[0]][3] = 1
  174.                         assign("gsocket" & $socketid, $so_name_and_ip[0], 2)
  175.                         _tcp_server_broadcast($socketid, "online")
  176.                 else
  177.                         dim $recvubound = ubound($_tcp_hsockets)
  178.                         redim $_tcp_hsockets[$recvubound 1][10]
  179.                         $_tcp_hsockets[$recvubound][0] = $socketid
  180.                         $_tcp_hsockets[$recvubound][1] = $socketip
  181.                         $_tcp_hsockets[$recvubound][2] = $name_and_ip
  182.                         $_tcp_hsockets[$recvubound][3] = 1
  183.                         assign("gsocket" & $socketid, $recvubound, 2)
  184.                         _tcp_server_broadcast($socketid, "online")
  185.                 endif
  186.         endif
  187. endfunc   ;==>_socketact

  189. func _tcp_server_broadcast($stext = "", $sendtype = "msg")
  190.         if stringupper($sendtype) = stringupper("online") or stringupper($sendtype) = stringupper("offline") then
  191.                 dim $stexta = $_tcp_hsockets[eval("gsocket" & $stext)][0] & "|" & $_tcp_hsockets[eval("gsocket" & $stext)][2]
  192.                 _clientline($stexta, $sendtype)
  193.         else
  194.                 dim $stexta = $stext
  195.         endif
  196.         if (ubound($_tcp_hsockets)) > 1 then
  197.                 dim $sendmsg = stringtobinary($mainstr & " 0 " & $sendtype & " " & $stexta & ", ", 4)
  198.                 for $i = 1 to ubound($_tcp_hsockets) - 1
  199.                         if stringupper($sendtype) = stringupper("online") or stringupper($sendtype) = stringupper("offline") then
  200.                                 if ubound($_tcp_hsockets) > $i then
  201.                                         if $_tcp_hsockets[$i][0] and $_tcp_hsockets[$i][0] <> $stext then
  202.                                                 tcpsend($_tcp_hsockets[$i][0], $sendmsg)
  203.                                                 if @error then
  204.                                                         $error = int(@error)
  205.                                                         if $_tcp_hsockets[$i][0] <> -1 then
  206.                                                                 $delsocket = $_tcp_hsockets[$i][0]
  207.                                                                 tcpclosesocket($_tcp_hsockets[$i][0])
  208.                                                         endif
  209.                                                         if $delsocket <> -1 then
  210.                                                                 _tcp_server_broadcast($delsocket, "offline")
  211.                                                         endif
  212.                                                 endif
  213.                                         endif
  214.                                 endif
  215.                         else
  216.                                 if $_tcp_hsockets[$i][0] then
  217.                                         tcpsend($_tcp_hsockets[$i][0], $sendmsg)
  218.                                         if @error then
  219.                                                 $error = int(@error)
  220.                                                 if $_tcp_hsockets[$i][0] <> -1 then
  221.                                                         $delsocket = $_tcp_hsockets[$i][0]
  222.                                                         tcpclosesocket($_tcp_hsockets[$i][0])
  223.                                                         if $delsocket <> -1 then
  224.                                                                 _tcp_server_broadcast($delsocket, "offline")
  225.                                                         endif
  226.                                                 endif
  227.                                         endif
  228.                                 endif
  229.                         endif
  230.                 next
  231.                 if $delsocket <> -1 then
  232.                         _arraydelete($_tcp_hsockets, eval("gsocket" & $delsocket))
  233.                         assign("gsocket" & $delsocket, -1, 2)
  234.                         $delsocket = -1
  235.                 endif
  236.         endif
  237. endfunc   ;==>_tcp_server_broadcast

  239. func _clientline($sonlineipstr = "", $sonlinemode = "")
  240.         if $sonlineipstr <> "" then
  241.                 dim $sonlinesp = stringsplit($sonlineipstr, "|", 1)
  242.                 if isarray($sonlinesp) then
  243.                         if ubound($sonlinesp) > 3 then
  244.                                 dim $sonlinesocket = $sonlinesp[1]
  245.                                 dim $sonlinename = $sonlinesp[2]
  246.                                 dim $sonlineip = $sonlinesp[3]
  247.                                 dim $getitemcount = _guictrllistview_getitemcount($listview3)
  248.                                 dim $sonline_id = _guictrllistview_findintext($listview3, $sonlinename & "|" & $sonlineip)
  249.                                 if $sonline_id <> -1 then
  250.                                         if stringupper($sonlinemode) = stringupper("offline") then
  251.                                                 traytip("通知", " " & $sonlineipstr & "已断开", 1, 1)
  252.                                                 _guictrllistview_deleteitem(guictrlgethandle($listview3), $sonline_id)
  253.                                         else
  254.                                                 traytip("通知", " " & $sonlinename & "已连接.", 1, 1)
  255.                                                 _guictrllistview_setitem($listview3, $sonlinesocket, $sonline_id, 1)
  256.                                         endif
  257.                                 else
  258.                                         if stringupper($sonlinemode) = stringupper("online") then
  259.                                                 traytip("通知", " " & $sonlinename & "已连接.", 1, 1)
  260.                                                 _guictrllistview_additem($listview3, $sonlinename & "|" & $sonlineip, $getitemcount)
  261.                                                 _guictrllistview_addsubitem($listview3, $getitemcount, $sonlinesocket, 1, 1)
  262.                                                 _guictrllistview_addsubitem($listview3, $getitemcount, $sonlinename, 2, 1)
  263.                                                 _guictrllistview_addsubitem($listview3, $getitemcount, $sonlineip, 3, 1)
  264.                                         endif
  265.                                 endif
  266.                         endif
  267.                 endif
  268.         endif
  269. endfunc   ;==>_clientline

  271. func sockettoip($shocket)
  272.         local $sockaddr, $aret
  273.         $sockaddr = dllstructcreate("short;ushort;uint;char[8]")
  274.         $aret = dllcall("ws2_32.dll", "int", "getpeername", "int", $shocket, "ptr", dllstructgetptr($sockaddr), "int*", dllstructgetsize($sockaddr))
  275.         if not @error and $aret[0] = 0 then
  276.                 $aret = dllcall("ws2_32.dll", "str", "inet_ntoa", "int", dllstructgetdata($sockaddr, 3))
  277.                 if not @error then $aret = $aret[0]
  278.         else
  279.                 $aret = 0
  280.         endif
  281.         $sockaddr = 0
  282.         return $aret
  283. endfunc   ;==>sockettoip

  285. func _skins3()
  286.         fileinstall("d:\au3\skin\享受风格.she", @tempdir & "\1.she", 1)
  287.         fileinstall("d:\au3\skin\skin.dll", @tempdir & "\skin.dll", 1)
  288.         $skins = @tempdir & "\1.she"
  289.         $dll = dllopen(@tempdir & "\skin.dll")
  290.         dllcall($dll, "int", "skinh_attachex", "str", $skins, "str", "mhgd")
  291.         filedelete(@tempdir & "\skin.dll")
  292.         filedelete(@tempdir & "\1.she")
  293. endfunc   ;==>_skins1
复制代码



本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？加入

×
yohoboy
发表于 2023-10-5 18:25:07 | 显示全部楼层
這個目前是我還在寫的，還沒寫完，你可以參考看看，重點是連進去後，透過接收字串，符合指定字串就重啟。
流程，
1.被控端開機後背景常駐，此客戶端需要指定一組固定ip，並啟動 tcp listen，待遠端登入。
2.主控端依list 選擇 tcp connect ，等待被控端回應已連線後(可以用回應字串確認已連線)，點擊重啟命令，重起命令可以使用特定字串，如 "real-time-reset" 送至被控端。
3.被控端接收字串後，確認符合 real-time-reset 這字串，立即執行 shutdown(6)



  1. #include
  2. #include

  4. opt("trayiconhide", 0)                 ;0 = 顯示托盤圖標, 1 = 隱藏托盤圖標
  5. opt('mustdeclarevars', 1)        ;0 = 變量不需預先聲明, 1 = 變量必需預先聲明
  6. opt("guicloseonesc", 0)         ;0 = 點擊 esc 鍵不關閉1 = 點擊 esc 鍵關閉,

  8. ;local $hgui = guicreate("bs_service",150,100,-1,-1)

  10. tcpstartup() ; 启动 tcp 服务.
  11. local $sipaddress = "127.0.0.1" ; 此 ip 地址仅用于在您自己的计算机上测试.
  12. local $iport = 65432 ; 用于连接的端口.
  13. global $ilistensocket = tcplisten($sipaddress, $iport,5)
  14. if @error then
  15.         local $ierror = @error
  16.     msgbox(bitor($mb_systemmodal, $mb_iconhand), "", "監聽失敗,錯誤代碼: " & $ierror)
  17. else
  18.     msgbox($mb_systemmodal, "", "監聽成功.",1)
  19. endif
  20. global $isocket_1 = -1, $isocket_2 = 0

  22. local $sreceived

  24. ;guisetstate(@sw_show, $hgui)

  26. ; 循环到用户退出.
  27. while 1
  28.         switch guigetmsg()
  29.                 case $gui_event_close
  30.                         tcpclosesocket($ilistensocket)
  31.                         sleep(1000)
  32.                         tcpshutdown()
  33.                         exitloop
  34.         endswitch

  36.         tcpconnlisten()

  38.     if $isocket_1 <> -1 then
  39.                 $sreceived = tcprecv($isocket_1, 10) ;
  40.                 if $sreceived <> "" then
  41.                         msgbox(0,"$sreceived",$sreceived,1)
  42.                         if $sreceived =  "reset" & @crlf then
  43.                                 tcpsend($isocket_1,"reset_ok")
  44.                                 tcpclosesocket($ilistensocket)
  45.                                 $sreceived = ""
  46.                                 $isocket_1 = -1
  47.                                 $isocket_2 = -1
  48.                                 tcpshutdown()
  49.                         else
  50.                                 $sreceived = ""
  51.                         endif
  52.                 endif
  53.         endif
  54. wend

  56. func tcpconnlisten()
  57.         local $ierror = ""
  58.         if $isocket_1 = -1 then
  59.                 if $isocket_2 = -1 then
  60.                         tcpstartup()
  61.                         $ilistensocket = tcplisten($sipaddress, $iport,5)
  62.                         $isocket_2 = 0
  63.                 endif
  64.                 $isocket_1 = tcpaccept($ilistensocket)
  65.                 if @error then
  66.                         $ierror = @error
  67.                         msgbox(bitor($mb_systemmodal, $mb_iconhand), "", "服务器:" & @crlf & "不能接收传入的连接，错误代码: " & $ierror)
  68.                 endif
  69.         endif

  71. endfunc
复制代码
gyp2000
发表于 2023-10-5 20:52:52 | 显示全部楼层
tcp代码比较复杂，用udp实现代码会更加简洁。
gyp2000
发表于 2023-10-5 21:02:52 | 显示全部楼层
  1. global $ipaddress = "127.0.0.1"
  2. global $port = 65432
  3. udpstartup()
  4. myudp_server($ipaddress, $port)
  5. msgbox(0, "", "关机")
  6. exit

  8. func myudp_server($sipaddress, $iport)
  9.         local $isocket = udpbind($sipaddress, $iport)
  10.         if @error then
  11.                 local $ierror = @error
  12.                 msgbox(0, "", "服务器:" & @crlf & "无法绑定，错误代码: " & $ierror)
  13.                 return false
  14.         endif
  15.         local $sreceived = ""
  16.         do
  17.                 $sreceived = udprecv($isocket, 4)
  18.         until $sreceived == "exit"
  19.         udpclosesocket($isocket)
  20. endfunc   ;==>myudp_server
复制代码
gyp2000
发表于 2023-10-5 21:22:57 | 显示全部楼层
本帖最后由 gyp2000 于 2023-10-5 21:27 编辑

tcp协议实现这种简单的功能就比较复杂了。
需要循环监听传入。然后创建连接套接字，远端断开连接后还需要释放套接字。
还需要做连接是否存活的监测，如果连接异常断开还需要释放套接字资源。
由于使用循环效率低，tcp服务端还会使用事件模式来处理远端连接请求、数据接收、远端断开连接这些事件。
一般没特殊需求，很少用tcp协议来处理这种简单需求。
发表于 2023-10-5 23:15:08 | 显示全部楼层
代码没看，我觉得，服务器给客户机发一个指令代码，比如发一个字符串shut，客户端就执行关机命令，发一个字符串restart，客户端就执行重启命令。当然用整数也可以，比如发一个0x01是关机，发一个0x02是重启。大概思路就这样吧。
wllx
 楼主| 发表于 2023-10-6 07:21:26 | 显示全部楼层

代码没看，我觉得，服务器给客户机发一个指令代码，比如发一个字符串shut，客户端就执行关机命令，发一个字 ...

思路不等于出路
这个是人家写的进程监视器服务端

#notrayicon
#region ;**** directives created by autoit3wrapper_gui ****
#autoit3wrapper_icon=d:\图标\多彩图标\apps\atom.ico
#autoit3wrapper_outfile=f:\mht_ys_ipxe\进程监视器服务端.exe
#autoit3wrapper_res_comment=进程监视器服务端
#autoit3wrapper_res_description=进程监视器服务端
#autoit3wrapper_res_fileversion=1.0.0.7
#autoit3wrapper_res_fileversion_autoincrement=y
#autoit3wrapper_res_legal国际棋牌 copyright=l4ever qq:425145
#endregion ;**** directives created by autoit3wrapper_gui ****
#notrayicon
#region ;**** 参数创建于 acnwrapper_gui ****
#endregion ;**** 参数创建于 acnwrapper_gui ****

#include
#include
#include
#include
#include
#include "tcp.au3"
#include
_winapi_wow64enablewow64fsredirection(false)
local $cofing = @scriptdir & "\wim\jydn\lan.ini"
_skin()
writelog("信息","程序启动,打开5138端口,并监听.")
_tcp_server_create(5138); 一个新的服务端
_tcp_registerevent($tcp_receive, "receive");收到数据
_tcp_registerevent($tcp_newclient, "newclient");客户端上线
local $itemcount3
global $guiclose=1,$next="none",$wating=0,$message=0,$localip=@ipaddress1,$connected=-1,$remoteip=1

$gui=guicreate("远控服务端",410,500)
$listview = guictrlcreatelistview("       机器名|        ip地址|         提示|             上线时间", 5, 5, 400,490)
guictrlsetfont(-1, 8.5, 400, 0, "微软雅黑")
_guictrllistview_setcolumnwidth($listview, 0, 80)
_guictrllistview_setcolumnwidth($listview, 1, 100)
_guictrllistview_setcolumnwidth($listview, 2, 80)
_guictrllistview_setcolumnwidth($listview, 3, 130)
$listmenu = guictrlcreatecontextmenu($listview)
$clsj = guictrlcreatemenuitem("退出", $listmenu)
guictrlsetfont(-1, 9, 400, 0, "微软雅黑")
$cqgj = guictrlcreatemenuitem("重启", $listmenu)
guictrlsetfont(-1, 9, 400, 0, "微软雅黑")
$gbgj = guictrlcreatemenuitem("关闭", $listmenu)
guictrlsetfont(-1,9, 400, 0, "微软雅黑")
$scgx = guictrlcreatemenuitem("删除", $listmenu)
guictrlsetfont(-1, 9, 400, 0, "微软雅黑")
$tightvnc= guictrlcreatemenuitem("连接", $listmenu)
guictrlsetfont(-1, 9, 400, 0, "微软雅黑")
guisetstate()

func receive($ierror, $sreceive)
        $str = stringreplace($sreceive,"killed","已上线")
        writelog("信息","收到客户端发送的报告,内容:"&$str)
        guictrlcreatelistviewitem($str&"|"&@year & "-" & @mon & "-" & @mday & " " & @hour & ":" & @min & ":" & @sec,$listview)
        beep(1000, 500)
endfunc

func newclient()
        writelog("信息","客户端上线")
endfunc

_guictrllistview_registersortcallback($listview)
while $guiclose
        sleep(10)
        $gui=guigetmsg()
        if $gui=$gui_event_close then $guiclose=0
        if $gui=$clsj then
                        _send2client("reset")
        endif

                 if $gui=$cqgj then
            _tcp_server_send("restart")
                         guictrldelete(guictrlread($listview))
                         guictrlsetdata($itemcount3,"待处理事件:"&_guictrllistview_getitemcount($listview))
        endif

                 if $gui=$gbgj then
            _tcp_server_send("shut")
                         guictrldelete(guictrlread($listview))
                         guictrlsetdata($itemcount3,"待处理事件:"&_guictrllistview_getitemcount($listview))
                 endif
                 if $gui=$scgx then
            guictrldelete(guictrlread($listview))
                        guictrlsetdata($itemcount3,"待处理事件:"&_guictrllistview_getitemcount($listview))
                endif
                if $gui=$listview then
                 _guictrllistview_sortitems($listview, guictrlgetstate($listview))
         endif
        wend

func _send2client($str)
        writelog("信息","响应人工操作,开始处理.")
        $listteam = stringsplit(guictrlread(guictrlread($listview)),"|")
                        if not @error then
                        $clientip = $listteam[2]
                        writelog("信息","选中的时间发生时间:"&$listteam[4]&",目标机器:["&$listteam[1]&"]"&$clientip&",事件:"&$listteam[3])
                else
                        writelog("错误","人工操作失败,可能是没选中列表内的项目.")
                        msgbox(16,"错误","请从列表中选中项目再操作.")
                        $clientip =""
                endif
if $clientip<> "" then
        tcpstartup()
        $connected=tcpconnect($clientip,5139)
        if not ($connected > 0) or @error then
                writelog("错误","连接"&$clientip&"失败,错误代码:"&@error)
                        else
                                writelog("信息","连接"&$clientip&"成功.socketid:"&$connected)
                        endif

        $sendresult = tcpsend($connected,$str)
        if $sendresult ="0" or @error then
                        writelog("错误","发送命令"&$str&"到"&$clientip&"失败,错误代码:"&@error)
                        else
                writelog("信息","发送命令"&$str&"到"&$clientip&"成功.")
                guictrldelete(guictrlread($listview))
                guictrlsetdata($itemcount3,"待处理事件:"&_guictrllistview_getitemcount($listview))
        endif
endif
tcpshutdown()
writelog("信息","关闭对该机的连接.")
writelog("信息","响应人工操作完成.")
endfunc

func _skin()
        $pf = iniread($cofing, "pf", "pf", "")
        $skins = @scriptdir & "\skin\" & $pf
        $dll = dllopen(@scriptdir & "\skin\skin.dll")
        dllcall($dll, "int", "skinh_attachex", "str", $skins, "str", "mhgd")
        dllcall($dll, "int", "skinh_setaero", "int", 1)
endfunc   ;==>_skins

func writelog($logact,$logcontent)
        $logfile= @scriptdir &"\"& stringtrimright(@scriptname,4)&".log"
        $logtime = @year & "-" & @mon & "-" & @mday & " " & @hour & ":" & @min & ":" & @sec &"." &@msec
        filewriteline($logfile,  $logtime & " | " & $logact & " | " & $logcontent)
endfunc

############
客户端：

;~ #notrayicon
#region ;**** 参数创建于 acnwrapper_gui ****
#autoit3wrapper_icon=c:\windows\system32\shell32.dll
#autoit3wrapper_outfile=进程监视器.exe
#autoit3wrapper_res_comment=进程监视器
#autoit3wrapper_res_description=进程监视器
#autoit3wrapper_res_fileversion=1.0.0.5
#autoit3wrapper_res_fileversion_autoincrement=y
#autoit3wrapper_res_legal国际棋牌 copyright=l4ever qq:425145
#endregion ;**** 参数创建于 acnwrapper_gui ****
#include "tcp.au3"
global $server = iniread(@scriptdir &"\lan.ini", "lan", "tcpip","")
global $process = iniread(@scriptdir &"\lan.ini", "lan", "进程","")
global $htime = iniread(@scriptdir &"\lan.ini", "lan", "循环时间","")
global $guiclose=1,$wating=0,$message=0,$localip=@ipaddress1,$connected=-1,$connok=0,$pcheckalert=0

if $server ="" or $process ="" then
        writelog("错误","配置错误,程序退出,请检查配置.")
        msgbox(0 16,"错误","配置错误,请检查配置，程序3秒后自动退出。",3)
        exit
endif

global $g_szversion = "processkeeper"
if winexists($g_szversion) then exit
autoitwinsettitle($g_szversion)

writelog("信息","程序启动,开始尝试连接服务端")
connserver()
writelog("信息","开始进行巡检检测,间隔时间为"&$htime&"毫秒")

if $connok = 1 then adlibregister("_pcheck",$htime)

while 1
        sleep(900)
        $command=tcprecv($connected,2048)
        if $command <> "" then
                writelog("信息","接收到服务端命令:"&$command)
                runcommand($command)
                $command = ""
        endif

wend

func runcommand($str1)
        writelog("信息","处理服务端发送的命令"&$str1)
        switch $str1
                case "reset"
                        writelog("信息","服务端要求初始化客户端程序,开始执行.")
                        connserver()
                        if $connok = 1 then adlibregister("_pcheck",$htime)
                case "restart"
                        writelog("信息","服务端要求重启客户机,开始执行.")
                        shutdown(6)
                        writelog("信息","服务端要求关闭客户机,开始执行.")
                case "shut"
                        shutdown(5)
        endswitch

        endfunc

func connserver()
        tcpstartup()
        $connected=tcpconnect($server,5138)
        if not ($connected > 0) or @error then
                writelog("错误","连接服务端失败,2秒后重试.错误代码:"&@error)
                                tcpshutdown()
                                sleep(2000)
                                connserver()
                                if $connok = 1 then adlibregister("_pcheck",$htime)
                        else
                                writelog("信息","连接服务端成功.socketid:"&$connected)
                                global $connok = 1
        endif
endfunc

func _pcheck()
if not processexists($process) then
                writelog("信息","客户端巡检检测发现异常,休眠2秒再次检测.")
                sleep(2000)
                if not processexists($process) then
                        writelog("信息","客户端巡检检测异常确认,开始向服务端发送报告.")
                        _senddata("killed")
                        writelog("信息","停止客户端巡检检测.")
                        adlibunregister("_pcheck")
                        _waitconn()
                endif
endif

        endfunc

func _senddata($str)
                $sendresult = tcpsend($connected,@computername&"|"&$localip&"|"&$str)
                        if $sendresult ="0" or @error then
                                writelog("错误","向服务端发送报告失败,错误代码:"&@error)
                                connserver()
                        else
                                global $sendresult = 1
                                writelog("信息","向服务端发送报告成功")
                        endif
endfunc

func writelog($logact,$logcontent)
        $logfile= @scriptdir &"\"& stringtrimright(@scriptname,4)&".log"
        $logtime = @year & "-" & @mon & "-" & @mday & " " & @hour & ":" & @min & ":" & @sec &"." &@msec
        filewriteline($logfile,  $logtime & " | " & $logact & " | " & $logcontent)
endfunc

func _waitconn()
        writelog("信息","转换模式,等待服务端处理.")
        _tcp_server_create(5139); 一个新的服务端
        _tcp_registerevent($tcp_receive, "receivec");收到数据
endfunc

func receivec($ierror, $sreceive)
        writelog("信息","收到服务端发送的数据:"&$sreceive)
        runcommand($sreceive)
endfunc

，这个就能关机重启，但是我不知道方法加入我的代码中
发表于 2023-10-6 15:27:08 | 显示全部楼层

思路不等于出路
这个是人家写的进程监视器服务端

这个好像我的风格呢。
wllx
 楼主| 发表于 2023-10-6 15:36:37 | 显示全部楼层

这个好像我的风格呢。



天下代码 一个样，这个是论坛一位同志写的进程监视器，老大，有没有办法套用一下他的关机、重启代码？
gyp2000
发表于 2023-10-6 17:54:09 来自手机 | 显示全部楼层
tcp通讯还存在数据包粘连和数据包截断的问题。虽然短小数据包出现这种问题的概率比较低。如果没有成熟的国际棋牌的解决方案，这种问题也不能忽略。
gyp2000
发表于 2023-10-6 20:56:46 来自手机 | 显示全部楼层
tcp来实现远程关机重启，相当于杀鸡用牛刀。au3内置指令只能实现部分tcp服务器功能。也没成熟的udf。想实现功能只能自己造轮子。
wllx
 楼主| 发表于 2023-10-6 21:23:37 | 显示全部楼层

tcp来实现远程关机重启，相当于杀鸡用牛刀。au3内置指令只能实现部分tcp服务器功能。也没成熟的udf。想实现 ...

你没注意到 上面那个进程监视器的代码就实现了远程关机，重启、指令客户端退出
gyp2000
发表于 2023-10-7 19:20:37 来自手机 | 显示全部楼层
人家的代码调用udf，贴出来的代码部分基本看不出tcp有关的部分。tcp服务器本身不难，比较难处理的是粘包的分离，和无效连接清理。最后就是代码效率问题。
下一页 »
12下一页
返回列表
您需要登录后才可以回帖 登录 | 加入

本版积分规则

||小黑屋|国际棋牌 ( ) "));

gmt 8, 2023-12-7 00:58 , processed in 0.109049 second(s), 21 queries .

powered by x3.5

© 2001-2023 .

返回列表
网站地图