# -*- coding: utf-8 -*-
import socket
import threading
# 目標(biāo)地址IP/URL及端口
target_host = "127.0.0.1"
target_port = 9999
# 創(chuàng)建一個(gè)socket對(duì)象
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 連接主機(jī)
client.connect((target_host,target_port))
def handle_send():
  while True:
    content = raw_input()
    client.send(content)
def handle_receive():
  while True:
    response = client.recv(4096)
    print response
send_handler = threading.Thread(target=handle_send,args=())
send_handler.start()
receive_handler = threading.Thread(target=handle_receive,args=())
receive_handler.start()

# -*- coding: utf-8 -*-
import socket
import threading
# 監(jiān)聽(tīng)的IP及端口
bind_ip = "127.0.0.1"
bind_port = 9999
#socket 服務(wù)器初始化
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind((bind_ip,bind_port))
server.listen(5)
print "[*] Listening on %s:%d" % (bind_ip,bind_port)
# 定義函數(shù)handle_client,輸入?yún)?shù)client_socket
def handle_client():
  while True:
    request = client_socket.recv(1024)
    print "[*] Received:%s" % request
def handle_send():
  while True:
    content = raw_input()
    client_socket.send(content);
#阻塞在這里，等待接收客戶(hù)端的數(shù)據(jù)
client_socket,addr = server.accept()
print "[*] Accept connection from:%s:%d" % (addr[0],addr[1])
#創(chuàng)建一個(gè)線(xiàn)程
client_handler = threading.Thread(target=handle_client,args=())
client_handler.start()
send_handler = threading.Thread(target=handle_send,args=())
send_handler.start()