network – 水色（仮）

#!/usr/bin/python3
# -*- coding:utf-8 -*-

import socket, select, json

TOKEN = '1234567'
HOST = '127.0.0.1'
PORT = 50009
SOCKET_TIMEOUT = 3  # seconds
BACKLOG = 10
BUFSIZE = 4096

# See: http://memo.saitodev.com/home/python_network_programing/
def initSocket():
    server_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    readfds = set([server_sock])
    try:
        server_sock.bind((HOST, PORT))
        server_sock.listen(BACKLOG)

        while True:
            rready, wready, xready = select.select(readfds, [], [])
            for sock in rready:
                if sock is server_sock:
                    # fd = sock.fileno()
                    # print("fd: %d" % fd)
                    sock.settimeout(SOCKET_TIMEOUT)
                    conn, address = server_sock.accept()
                    readfds.add(conn)
                else:
                    buffer = sock.recv(BUFSIZE)
                    if len(buffer) == 0:
                        sock.close()
                        readfds.remove(sock)
                    else:
                        ret = getSendValue(command(buffer))
                        sock.send(ret)
                        #
                        sock.close()
                        readfds.remove(sock)
    except Exception as e:
        print("Exception: " + str(e))
    finally:
        for sock in readfds:
            sock.close()
        server_sock.close()

# @param buffer receive buffer data
# @return dict
def command(buffer):
    try:
        data = getReceiveValue(buffer)
        print("Receive: ", data)

        if 'token' not in data or data['token'] != TOKEN:
            msg = "token error."
            print(msg)
            return {"message": msg}
        if 'command' not in data:
            msg = "Receive message is failed, key 'command' not found."
            print(msg)
            return {"message": msg}
        cmd = data['command']
        return {"Receive command": cmd}
    except Exception as e:
        return {"exception": str(e)}

def getReceiveValue(buffer):
    return json.JSONDecoder().decode(buffer.decode('utf-8').strip())

def getSendValue(value):
    if not (isinstance(value, list) or isinstance(value, dict) or isinstance(value, tuple)):
        value = {value}
    return bytes(json.JSONEncoder().encode(value), 'utf-8')

def main():
    print("Backend start")
    while True:
        initSocket()
    print("Escape main loop...")

if __name__ == '__main__':
    main()

#!/usr/bin/python3

# -*- coding:utf-8 -*-

import socket, select, json

TOKEN = '1234567'

HOST = '127.0.0.1'

PORT = 50009

SOCKET_TIMEOUT = 3 # seconds

BACKLOG = 10

BUFSIZE = 4096

# See: http://memo.saitodev.com/home/python_network_programing/

def initSocket():

server_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

server_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

readfds = set([server_sock])

try:

server_sock.bind((HOST, PORT))

server_sock.listen(BACKLOG)

while True:

rready, wready, xready = select.select(readfds, [], [])

for sock in rready:

if sock is server_sock:

# fd = sock.fileno()

# print("fd: %d" % fd)

sock.settimeout(SOCKET_TIMEOUT)

conn, address = server_sock.accept()

readfds.add(conn)

else:

buffer = sock.recv(BUFSIZE)

if len(buffer) == 0:

sock.close()

readfds.remove(sock)

else:

ret = getSendValue(command(buffer))

sock.send(ret)

sock.close()

readfds.remove(sock)

except Exception as e:

print("Exception: " + str(e))

finally:

for sock in readfds:

sock.close()

server_sock.close()

# @param buffer receive buffer data

# @return dict

def command(buffer):

try:

data = getReceiveValue(buffer)

print("Receive: ", data)

if 'token' not in data or data['token'] != TOKEN:

msg = "token error."

print(msg)

return {"message": msg}

if 'command' not in data:

msg = "Receive message is failed, key 'command' not found."

print(msg)

return {"message": msg}

cmd = data['command']

return {"Receive command": cmd}

except Exception as e:

return {"exception": str(e)}

def getReceiveValue(buffer):

return json.JSONDecoder().decode(buffer.decode('utf-8').strip())

def getSendValue(value):

if not (isinstance(value, list) or isinstance(value, dict) or isinstance(value, tuple)):

value = {value}

return bytes(json.JSONEncoder().encode(value), 'utf-8')

def main():

print("Backend start")

while True:

initSocket()

print("Escape main loop...")

if __name__ == '__main__':

main()

<?php

$sendMessage = array(
    'cmd' => 'commandA',
);
$result = commBackend($sendMessage);
print_r($result);

function commBackend($sendMessage) {

    $sendMessage['token'] = '1234567';

    $address = '127.0.0.1';
    $service_port = 50009;
    $timeout_sec = 3;   // sec
    $timeout = time() + $timeout_sec;

    try {
        $fp = fsockopen($address, $service_port);
        if (!$fp) {
            throw new Exception('Cannot communicate Backend.');
        }
        // non blocking, need to timeout.
        stream_set_blocking($fp ,0);
        stream_set_timeout($fp, $timeout_sec);

        fwrite($fp, json_encode($sendMessage));

        $contents = '';
        do {
            if ($timeout - time() <= 0) {
                $timeout = -1;
                break;
            }
            // echo '.';
            $contents .= fread($fp, 8192);
        } while (!feof($fp));

        $info = stream_get_meta_data($fp);
        // print_r($info);
        fclose($fp);

        if ($info['timed_out'] || $timeout === -1) {
            throw new Exception('Communication with the backend timed out.');
        }

        // echo $contents;
        $res = json_decode($contents);    // json string to object
        // print_r($res);
        return $res;

    } catch (Exception $e) {
        echo $e->getMessage();
        throw new Exception($e->getMessage());
    }
}

<?php

$sendMessage = array(

'cmd' => 'commandA',

);

$result = commBackend($sendMessage);

print_r($result);

function commBackend($sendMessage) {

$sendMessage['token'] = '1234567';

$address = '127.0.0.1';

$service_port = 50009;

$timeout_sec = 3; // sec

$timeout = time() + $timeout_sec;

try {

$fp = fsockopen($address, $service_port);

if (!$fp) {

throw new Exception('Cannot communicate Backend.');

}

// non blocking, need to timeout.

stream_set_blocking($fp ,0);

stream_set_timeout($fp, $timeout_sec);

fwrite($fp, json_encode($sendMessage));

$contents = '';

do {

if ($timeout - time() <= 0) {

$timeout = -1;

break;

}

// echo '.';

$contents .= fread($fp, 8192);

} while (!feof($fp));

$info = stream_get_meta_data($fp);

// print_r($info);

fclose($fp);

if ($info['timed_out'] || $timeout === -1) {

throw new Exception('Communication with the backend timed out.');

}

// echo $contents;

$res = json_decode($contents); // json string to object

// print_r($res);

return $res;

} catch (Exception $e) {

echo $e->getMessage();

throw new Exception($e->getMessage());

}

サーバー側 (接続される側) の設定

セキュリティ対策ツール Ver.11

設定

不正サイト/迷惑メール対策

ネットワーク対策

ファイアウォールチューナーを有効にする → 無効

例外設定

ファイル/フォルダ

vncserver を追加

Windows 10

コントロールパネル > システムとセキュリティ > Windows Defender ファイアウォール → 無効

IPアドレスの固定と電源オプションでスリープにしない設定も

コマンドラインからのサーバー実行について – 26 Mar 2019

バージョン

UltraVNC_1_2_24_X64_Setup.exe
UltraVNC_1_2_24_X86_Setup.exe

サービスとして実行しておくと、ユーザーアカウント制御 (UAC; User Account Control) の画面が出ても遠隔操作を続けられる

・起動

winvnc.exe

・停止

winvnc.exe -kill

・サービスとして登録・実行 ※管理者として実行

powershell start-process winvnc.exe -ArgumentList “-install” -verb runas

・サービス登録解除・停止 ※管理者として実行

powershell start-process winvnc.exe -ArgumentList “-uninstall” -verb runas

・”-remove” オプションは無いみたい

powershell start-process winvnc.exe -ArgumentList “-remove” -verb runas

—

クイックアシスト / Windows Quick Assist

golang で UPnP をサポートするルーターを検出し、ルーターの外部ポートをローカル PC の転送ポートにマップする / Detects routers that support UPnP and maps the router’s external ports to forward ports on the local PC with golang

タグ: network

クライアントの帯域制限を Apache2 に含まれているモジュールでやってみる / Tried limite the client boundwidth rate limit with Bandwidth Rate Limiting for Clients of included module in Apache

Socket sync communication test between PHP7 and Python3

UltraVNC が接続できなかった時に行った設定メモ