jmeter与tcp和udp建立连接

# -*- coding:utf-8 -*-
#@Time : 2020/5/17 20:18
#@Author: 张君
#@File : server_test.py

# encoding=utf-8

import socketserver
import threading

class MyTCPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            self.data = self.request.recv(1024).strip()
            cur_thread = threading.current_thread()
            print(cur_thread)
            if not self.data:
                print(u"客户端:%s 退出!" % self.client_address[0])
                break
            print(u"%s 内容:%s" % (self.client_address[0], self.data.decode("utf-8")))
##            self.request.sendall(self.data.upper()+‘\n‘.encode("utf-8"))
            self.request.sendall(self.data.upper()+‘\n‘.encode("utf-8"))   #转为大写字母后返回给客户端
		    # 可以加一个服务端断开的


if __name__ == "__main__":
    HOST, PORT = "", 8001
    server = socketserver.ThreadingTCPServer((HOST, PORT), MyTCPHandler)
    print("启动了")
    server.serve_forever()
    #server.server_close()

# -*- coding:utf-8 -*-
#@Time : 2020/5/17 20:17
#@Author: 张君
#@File : client_test.py

import logging, time, socket, struct, binascii

target_host = "127.0.0.1"

target_port = 8001
# AF_INET指定使用IPv4协议，如果要用更先进的IPv6，就指定为AF_INET
# SOCK_STREAM指定使用面向流的TCP协议
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect((target_host, target_port))


for i in range(1):
    msg="zhangjun"
    client.send(msg.encode("utf-8"))
    response = client.recv(2048)
    logging.info("响应bytes是: {}".format(response))

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

s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind(("127.0.0.1", 3600))
print("UDP bound on port 3600...")

while True:
    data, addr = s.recvfrom(1024)
    print("Receive from %s:%s" % addr)
    if data == b"exit":
        s.sendto(b"Good bye!\n", addr)
        continue
    s.sendto(b"Hello %s!\n" % data, addr)