SparkSQL極速入門統合Kudu広告業務データ分析を実現
2891 ワード
download: SparkSQL極速入門統合Kudu広告業務データ分析を実現
サーバ側コード、server_tcp.py
!/usr/bin/env python
-- coding:utf-8 --
クライアントから送信されたコマンドを実行し、実行結果をクライアントに返します.
import socket, traceback, subprocess
host = ''port = 51888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((host, port))s.listen(1)
while 1:
2.クライアントコードclient_tcp.py
!/usr/bin/env python
-- coding:utf-8 --
サーバ側にコマンドを送信
import socket, sys, traceback
host = '127.0.0.1'port = 51888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)try:
except Exception, e:
input_command = raw_input('Input command:')s.send(input_command)
shutdown()関数によるsocket双方向データ転送を一方向データ転送に変更
このパラメータはsocketを閉じる方法を示します.具体的には、0は将来の読書を禁止することを示す.1は将来書くことを禁止することを表す.2将来の読み書きを禁止する
s.shutdown(1)print'送信完了.'print'受信内容:'while 1:
3.server_の起動tcp.pyスクリプト、ネイティブ51888ポートの傍受を開始します.次にクライアントを起動します.tcp.py.(1)クライアントの内容:
/usr/bin/python2.7/home/wuguowei/PycharmProjects/xplan_script/test_process/client_tcp.pyInput command:ls-l送信完了.受信内容:
総使用量20
-rw-r--r--1 root root 744 2月10 14:44 client_tcp.py
-rw-r--r--1 root root 877 2月10 14:18 my_sub_process.py
-rw-r--r--1 root root 1290 2月10 14:45 server_tcp.py
-rw-r--r--1 root root 493 2月10:43 tcpclient.py
-rw-r--r--1 root root 1168 2月10 11:51 tcpserver.py
okProcess finished with exit code 0
(2)サーバ側情報
/usr/bin/python2.7/home/wuguowei/PycharmProjects/xplan_script/test_process/server_tcp.pyFrom host: ('127.0.0.1', 46993)127.0.0.1:ls -l
サーバ側コード、server_tcp.py
!/usr/bin/env python
-- coding:utf-8 --
クライアントから送信されたコマンドを実行し、実行結果をクライアントに返します.
import socket, traceback, subprocess
host = ''port = 51888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((host, port))s.listen(1)
while 1:
try:
client_socket, client_addr = s.accept()
except Exception, e:
traceback.print_exc()
continue
try:
print 'From host:', client_socket.getpeername()
while 1:
command = client_socket.recv(4096)
if not len(command):
break
print client_socket.getpeername()[0] + ':' + str(command)
#
handler = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE)
output = handler.stdout.readlines()
if output is None:
output = []
for one_line in output:
client_socket.sendall(one_line)
client_socket.sendall("
")
client_socket.sendall("ok")
except Exception, e:
traceback.print_exc()
try:
client_socket.close()
except Exception, e:
traceback.print_exc()
2.クライアントコードclient_tcp.py
!/usr/bin/env python
-- coding:utf-8 --
サーバ側にコマンドを送信
import socket, sys, traceback
host = '127.0.0.1'port = 51888
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)try:
s.connect((host, port))
except Exception, e:
msg = traceback.format_exc()
print ' :', msg
input_command = raw_input('Input command:')s.send(input_command)
shutdown()関数によるsocket双方向データ転送を一方向データ転送に変更
このパラメータはsocketを閉じる方法を示します.具体的には、0は将来の読書を禁止することを示す.1は将来書くことを禁止することを表す.2将来の読み書きを禁止する
s.shutdown(1)print'送信完了.'print'受信内容:'while 1:
buff = s.recv(4096)
if not len(buff):
break
sys.stdout.write(buff)
3.server_の起動tcp.pyスクリプト、ネイティブ51888ポートの傍受を開始します.次にクライアントを起動します.tcp.py.(1)クライアントの内容:
/usr/bin/python2.7/home/wuguowei/PycharmProjects/xplan_script/test_process/client_tcp.pyInput command:ls-l送信完了.受信内容:
総使用量20
-rw-r--r--1 root root 744 2月10 14:44 client_tcp.py
-rw-r--r--1 root root 877 2月10 14:18 my_sub_process.py
-rw-r--r--1 root root 1290 2月10 14:45 server_tcp.py
-rw-r--r--1 root root 493 2月10:43 tcpclient.py
-rw-r--r--1 root root 1168 2月10 11:51 tcpserver.py
okProcess finished with exit code 0
(2)サーバ側情報
/usr/bin/python2.7/home/wuguowei/PycharmProjects/xplan_script/test_process/server_tcp.pyFrom host: ('127.0.0.1', 46993)127.0.0.1:ls -l