server.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "id": "547cf643",
   "metadata": {},
   "outputs": [
    {
     "name": "stderr",
     "output_type": "stream",
     "text": [
      "Matplotlib created a temporary config/cache directory at /tmp/matplotlib-d1drjh4x because the default path (/home/anbang/.config/matplotlib) is not a writable directory; it is highly recommended to set the MPLCONFIGDIR environment variable to a writable directory, in particular to speed up the import of Matplotlib and to better support multiprocessing.\n"
     ]
    }
   ],
   "source": [
    "import numpy as np\n",
    "import pandas as pd\n",
    "import os\n",
    "import matplotlib.pyplot as plt\n",
    "import seaborn as sns\n",
    "#import geopandas as gpd\n",
    "import re\n",
    "import sklearn\n",
    "import numpy as np\n",
    "from sklearn.neighbors import NearestNeighbors\n",
    "import socket\n",
    "import sys\n",
    "import threading\n",
    "import json\n",
    "import numpy as np\n",
    "%matplotlib inline\n",
    "plt.rcParams['figure.figsize'] = (12, 5);\n",
    "sns.set_style('whitegrid')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 2,
   "id": "6abfecec",
   "metadata": {},
   "outputs": [],
   "source": [
    "customer_array = np.load(\"customer_array.npy\",allow_pickle=True)\n",
    "customer_rare_array = np.load(\"customer_rare_array.npy\",allow_pickle=True)\n",
    "by_customer_rare = pd.read_csv('./by_customer_rare.csv')\n",
    "by_customer = pd.read_csv('./by_customer.csv')\n",
    "customer_rare = pd.read_csv('./customer_rare.csv')\n",
    "customer = pd.read_csv('./customer.csv')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 3,
   "id": "ac72a298",
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "NearestNeighbors()"
      ]
     },
     "execution_count": 3,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "'''\n",
    "samples = [[0, 0, 2], [1, 0, 0], [0, 0, 1]]\n",
    "neigh = NearestNeighbors(2, 0.4)\n",
    "neigh.fit(samples) \n",
    "neigh.kneighbors([[0, 0, 1.3]], 2, return_distance=False)\n",
    "'''\n",
    "neigh = NearestNeighbors()\n",
    "neigh.fit(customer_array) \n",
    "\n",
    "neigh_rare = NearestNeighbors()\n",
    "neigh_rare.fit(customer_rare_array) "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "id": "767e56bc",
   "metadata": {},
   "outputs": [],
   "source": [
    "by_customer = by_customer.set_index('customer_id')\n",
    "by_customer_rare = by_customer_rare.set_index('customer_id')"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "id": "cc6f9c7b",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "b'#AFSDG,0 0 2 0.0329 -78.6 10000.0 9.0 0 0 0 1 0 0 0 0 0 0 0 0 0 0 6 0 0 0 0 0 0 0 0 0 0 1 1 0 0 0 0 0 0 1 1 0 0 0 0 0 0 0 0 0 0 0 1 1 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 1 0 0 0 0 0 0 1 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0.0 0.2222222222222222@'\n"
     ]
    }
   ],
   "source": [
    "#sample data format\n",
    "Q = [[0, 0, 2, 0.0329, -78.6, 10000.0, 9.0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0,\n",
    "       0, 0, 0, 0, 6, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 0, 0, 0, 0, 0,\n",
    "       0, 1, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 0, 0, 0, 0, 0, 0,\n",
    "       0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0,\n",
    "       0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0.0,\n",
    "       0.2222222222222222]]\n",
    "\n",
    "to_send = \"#AFSDG,\"+\" \".join([str(i) for i in Q[0]])+\"@\"\n",
    "to_send_encoded = to_send.encode(\"utf-8\")\n",
    "print(to_send_encoded)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 6,
   "id": "f65c7a88",
   "metadata": {},
   "outputs": [
    {
     "data": {
      "text/plain": [
       "['259', '43', '243']"
      ]
     },
     "execution_count": 6,
     "metadata": {},
     "output_type": "execute_result"
    }
   ],
   "source": [
    "\n",
    "def query(user_vecs, neigh, table, pool, k_value=3, return_num=1):\n",
    "    dist, knn = neigh.kneighbors(user_vecs, k_value, return_distance=True)\n",
    "    recommendation = []\n",
    "    recommendation_weight = []\n",
    "    #print(dist,knn)\n",
    "    for k,i in enumerate(list(knn)):\n",
    "        \n",
    "        #print(pool.iloc[i])\n",
    "        user_id = table.iloc[i]['customer_id'].values\n",
    "        recommended_restaurant = []\n",
    "        for id in user_id:\n",
    "            recommended_restaurant.append(pool.loc[id]['VENDOR'].split(' '))\n",
    "        confidence = {}\n",
    "        for j in range(len(recommended_restaurant)):\n",
    "            for restaurant in recommended_restaurant[j]:\n",
    "                if restaurant not in confidence:\n",
    "                    confidence[restaurant]=0.\n",
    "                confidence[restaurant]+=1./dist[0][j]\n",
    "        p = np.asarray(list(confidence.values()))\n",
    "        p/=np.sum(p)\n",
    "        keys = list(confidence.keys())\n",
    "        recommendation.append(np.random.choice(len(confidence.keys()), return_num, p=p,replace=False))\n",
    "        ret = [keys[recommendation[-1][n]]for n in range(return_num)]\n",
    "        #print(\"generate recommendation for %d'th input...\"%k)\n",
    "        #print(\"--Recommendation is restaurant: \"+str(ret))\n",
    "        return ret\n",
    "        \n",
    "\n",
    "def generate_recommendation(user_vecs):\n",
    "    l1 = query(user_vecs, neigh, customer, by_customer, k_value=3, return_num=2)\n",
    "    l2 = query(user_vecs, neigh_rare, customer_rare, by_customer_rare, k_value=3, return_num=1)\n",
    "    l1.extend(l2)\n",
    "    return l1\n",
    "\n",
    "def worker(worker_id,que1,que2):\n",
    "    #read cosumer queue put result to writer queue\n",
    "    customer_array = np.load(\"customer_array.npy\",allow_pickle=True)\n",
    "    customer_rare_array = np.load(\"customer_rare_array.npy\",allow_pickle=True)\n",
    "    by_customer_rare = pd.read_csv('./by_customer_rare.csv')\n",
    "    by_customer = pd.read_csv('./by_customer.csv')\n",
    "    customer_rare = pd.read_csv('./customer_rare.csv')\n",
    "    customer = pd.read_csv('./customer.csv')\n",
    "    neigh = NearestNeighbors()\n",
    "    neigh.fit(customer_array) \n",
    "    \n",
    "    neigh_rare = NearestNeighbors()\n",
    "    neigh_rare.fit(customer_rare_array) \n",
    "    by_customer = by_customer.set_index('customer_id')\n",
    "    by_customer_rare = by_customer_rare.set_index('customer_id')\n",
    "    #sample data format\n",
    "    Q = [[0, 0, 2, 0.0329, -78.6, 10000.0, 9.0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0,\n",
    "           0, 0, 0, 0, 6, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 0, 0, 0, 0, 0,\n",
    "           0, 1, 1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 1, 0, 0, 0, 0, 0, 0,\n",
    "           0, 0, 0, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0, 1, 0, 0, 0, 0, 0,\n",
    "           0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0.0,\n",
    "           0.2222222222222222]]\n",
    "    \n",
    "    to_send = \"#AFSDG,\"+\" \".join([str(i) for i in Q[0]])+\"@\"\n",
    "    to_send_encoded = to_send.encode(\"utf-8\")\n",
    "    \n",
    "    def query(user_vecs, neigh, table, pool, k_value=3, return_num=1):\n",
    "        dist, knn = neigh.kneighbors(user_vecs, k_value, return_distance=True)\n",
    "        recommendation = []\n",
    "        recommendation_weight = []\n",
    "        #print(dist,knn)\n",
    "        for k,i in enumerate(list(knn)):\n",
    "            \n",
    "            #print(pool.iloc[i])\n",
    "            user_id = table.iloc[i]['customer_id'].values\n",
    "            recommended_restaurant = []\n",
    "            for id in user_id:\n",
    "                recommended_restaurant.append(pool.loc[id]['VENDOR'].split(' '))\n",
    "            confidence = {}\n",
    "            for j in range(len(recommended_restaurant)):\n",
    "                for restaurant in recommended_restaurant[j]:\n",
    "                    if restaurant not in confidence:\n",
    "                        confidence[restaurant]=0.\n",
    "                    confidence[restaurant]+=1./dist[0][j]\n",
    "            p = np.asarray(list(confidence.values()))\n",
    "            p/=np.sum(p)\n",
    "            keys = list(confidence.keys())\n",
    "            recommendation.append(np.random.choice(len(confidence.keys()), return_num, p=p,replace=False))\n",
    "            ret = [keys[recommendation[-1][n]]for n in range(return_num)]\n",
    "            #print(\"generate recommendation for %d'th input...\"%k)\n",
    "            #print(\"--Recommendation is restaurant: \"+str(ret))\n",
    "            return ret\n",
    "        \n",
    "    def generate_recommendation(user_vecs):\n",
    "        l1 = query(user_vecs, neigh, customer, by_customer, k_value=3, return_num=2)\n",
    "        l2 = query(user_vecs, neigh_rare, customer_rare, by_customer_rare, k_value=3, return_num=1)\n",
    "        l1.extend(l2)\n",
    "        return l1\n",
    "    print(\"add worker\",worker_id)\n",
    "    while True:\n",
    "        task = que1.get()\n",
    "        if task:\n",
    "            #print(\"worker %d handle tasks\"%worker_id)\n",
    "            recommendation = generate_recommendation([task[0][1]])\n",
    "            #print(recommendation)\n",
    "            que2.put([(str(worker_id).encode(\"utf-8\")+b'#'+task[0][0],recommendation)])\n",
    "\n",
    "\n",
    "generate_recommendation(Q)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "fd7b1330",
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": 7,
   "id": "27a7ae61",
   "metadata": {},
   "outputs": [],
   "source": [
    "import multiprocessing\n",
    "\n",
    "    \n",
    "    \n",
    "def reader(que1, que2):\n",
    "    # read user_vec from client, put into cosumer queue\n",
    "    # que obj support internal blocking mechanism, maybe don't need a lock\n",
    "    print(\"setting server reader\")\n",
    "    host = socket.gethostname()\n",
    "    port = 12345\n",
    "    port2 = 12344\n",
    "    \n",
    "    #server side\n",
    "    clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)\n",
    "    clientsocket.bind((host, port2))\n",
    "    clientsocket.listen()\n",
    "    \n",
    "    recv_data = b\"\"\n",
    "    \n",
    "    #client side\n",
    "    serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)\n",
    "    serversocket.connect((host, port2))\n",
    "    myaddr = serversocket.getsockname()\n",
    "    clientsocket.settimeout(10)\n",
    "    print(\"server addr:%s\" % str(myaddr))\n",
    "    t, address = clientsocket.accept()\n",
    "    while True:\n",
    "        #print(\"client addr:\",str(address),\" server address:\",str(serversocket.getsockname()))\n",
    "        serversocket.send(to_send_encoded)    #client send test instance to server\n",
    "        serversocket.send(to_send_encoded)    #client send test instance to server\n",
    "        serversocket.send(to_send_encoded)    #client send test instance to server\n",
    "        serversocket.send(to_send_encoded)    #client send test instance to server\n",
    "        tmp = t.recv(1024)    #server accept test instance from server\n",
    "        if len(tmp) == 0:\n",
    "            raise Exception()\n",
    "        recv_data += tmp\n",
    "        l = recv_data.split(b'@')\n",
    "        recv_data = l[-1]\n",
    "        for i in range(len(l)-1):\n",
    "            token = l[i][1:7]\n",
    "            raw_data = l[i][7:].split(b' ')\n",
    "            #print(raw_data)\n",
    "            raw_data = [float(k) for k in raw_data]\n",
    "            que1.put([(token,raw_data)])\n",
    "        \n",
    "            \n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "075e991e",
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "8c81581b",
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "setting server reader\n",
      "writer server addr:('127.0.0.1', 36220)server addr:('127.0.0.1', 37672)\n",
      "\n",
      "add worker 1\n",
      "add workeradd worker add worker  523test client receive: \n",
      "\n",
      " add worker\n",
      " b'#1#AFSDG,304 43 243@'4\n",
      "\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n"
     ]
    },
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 43 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,43 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,259 304 243@'\n",
      "test client receive:  b'#4#AFSDG,259 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,304 259 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#3#AFSDG,304 259 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,259 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 259 243@'\n",
      "test client receive:  b'#1#AFSDG,43 259 243@'\n",
      "test client receive:  b'#3#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,43 304 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#5#AFSDG,304 259 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#1#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 259 243@'\n",
      "test client receive:  b'#1#AFSDG,259 43 243@'\n",
      "test client receive:  b'#5#AFSDG,304 43 243@'\n",
      "test client receive:  b'#3#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,304 43 243@'\n",
      "test client receive:  b'#1#AFSDG,259 304 243@'\n",
      "test client receive:  b'#5#AFSDG,43 304 243@'\n",
      "test client receive:  b'#4#AFSDG,304 43 243@'\n",
      "test client receive:  b'#2#AFSDG,259 304 243@'\n",
      "test client receive:  "
     ]
    }
   ],
   "source": [
    "def writer(que1,que2):\n",
    "    # read out writer queue send back results to client\n",
    "    # return binary encoded str, b'#2#AFSDG,259 43 243@'\n",
    "    #worker_id#token,recomendation1 recomendation2 recomendation3\n",
    "    host = socket.gethostname()\n",
    "    port = 12345\n",
    "    port2 = 12344\n",
    "    \n",
    "    #server side\n",
    "    testsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)\n",
    "    testsocket.bind((host, port))\n",
    "    testsocket.listen()\n",
    "    \n",
    "    \n",
    "    #client side\n",
    "    clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)\n",
    "    clientsocket.connect((host, port))\n",
    "    myaddr = clientsocket.getsockname()\n",
    "    testsocket.settimeout(10)\n",
    "    t, address = testsocket.accept()\n",
    "    print(\"writer server addr:%s\" % str(myaddr))\n",
    "    while True:\n",
    "        task = que2.get()\n",
    "        if task:\n",
    "            #print(\"writer write result\")\n",
    "            to_send_encoded = b'#'+task[0][0]+' '.join(task[0][1]).encode(\"utf-8\")+b'@'\n",
    "            #print(to_send_encoded)\n",
    "            clientsocket.send(to_send_encoded)  \n",
    "            tmp = t.recv(1024)    #server accept test instance from server\n",
    "            if len(tmp) == 0:\n",
    "                continue\n",
    "            print(\"test client receive: \",tmp)   #--> should output test client receive:  b'#AFSDG,259 43 243@'\n",
    "            \n",
    "    return \n",
    "\n",
    "pool = multiprocessing.Pool(processes=12)\n",
    "m = multiprocessing.Manager()\n",
    "q1 = m.Queue()\n",
    "q2 = m.Queue()\n",
    "workers = []\n",
    "process1 = pool.apply_async(reader, (q1,q2))\n",
    "process2 = pool.apply_async(worker, (1,q1,q2))\n",
    "process3 = pool.apply_async(worker, (2,q1,q2))\n",
    "process4 = pool.apply_async(worker, (3,q1,q2))\n",
    "process5 = pool.apply_async(worker, (4,q1,q2))\n",
    "process6 = pool.apply_async(worker, (5,q1,q2))\n",
    "process7 = pool.apply_async(writer, (q1,q2))\n",
    "pool.close()\n",
    "pool.join()"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "33c1184f",
   "metadata": {},
   "outputs": [],
   "source": []
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "7b3e4d2b",
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3 (ipykernel)",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.8.11"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 5
}