{"id":509,"date":"2020-11-03T00:11:20","date_gmt":"2020-11-02T16:11:20","guid":{"rendered":"https:\/\/whalefallnotes.blog\/?p=509"},"modified":"2024-10-29T00:55:35","modified_gmt":"2024-10-28T16:55:35","slug":"simple-multiplexing-in-python3","status":"publish","type":"post","link":"https:\/\/whalefallnotes.blog\/zh\/2020\/11\/03\/simple-multiplexing-in-python3\/","title":{"rendered":"Multiplexing in Python3"},"content":{"rendered":"\n

What is Multiplexing<\/strong> and De-multiplexing?<\/strong><\/p>\n\n\n\n

\"\"<\/figure>\n\n\n\n

Multiplexing is generally representing a concept of transferring multiple messages by the same road. By merging the slow road to a faster road, can efficiently bring advantage to the usage of the faster road. After the data has proceeded when the messages arrive at the destination server, we need to use De-multiplexing to the different sources. The advantage of multiplexing that includes saving the cost and efficiently use the resources for communication.<\/p>\n\n\n\n

Server-side example<\/p>\n\n\n\n

\nimport socket\nimport queue\nimport select\n\nbuffer = 1024\navailable_connections = 1000\nserver = socket.socket()\nserver.bind(('localhost', 8888))\nserver.listen(available_connections)\nserver.setblocking(False)\nmessage_redirect = {}\ninputs = [server, ]\noutputs = []\n\n\ndef add_readable(readable):\n    global<\/em> buffer\n    global<\/em> inputs\n    global<\/em> outputs\n    global<\/em> server\n    global<\/em> message_redirect\n    for r in readable:\n        if r is server:\n            conn, addr = server.accept()\n            inputs.append(conn)\n            message_redirect[conn] = queue.Queue()\n        else:\n            data = r.recv(buffer)\n            message_redirect[r].put(data)\n            outputs.append(r)\n\n\ndef add_writable(writeable):\n    global<\/em> outputs\n    global<\/em> message_redirect\n    for w in writeable:\n        data_to_client = message_redirect[w].get()\n        w.send(data_to_client)\n        outputs.remove(w)\n\n\ndef exception_handler():\n    global<\/em> inputs\n    global<\/em> outputs\n    global<\/em> message_redirect\n    for e in exceptional:\n        if e in outputs:\n            outputs.remove(e)\n        inputs.remove(e)\n        del message_redirect[e]\n\n\nwhile True:\n    readable, writeable, exceptional = select.select(inputs, outputs, inputs)\n    add_readable(readable)\n    add_writable(writeable)\n    exception_handler()\n\n<\/code><\/pre>\n\n\n\n
Client-side example (Test client)<\/p>\n\n\n\n
\nimport socket\nimport time\nimport socket\nimport sys\n\nbuffer = 1024\nhost = '127.0.0.1'\nport = 8888\n\n\ndef send_msg(sock):\n    global<\/em> buffer\n    while True:\n        sock.send(bytes(str.encode('test')))\n        msg = sock.recv(buffer)\n        print(msg.decode('utf-8'))\n        time.sleep(2)\n\n\ndef main():\n    global<\/em> host\n    global<\/em> port\n    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:\n        sock.connect((host, port))\n        send_msg(sock)\n\n\nif __name__ == \"__main__\":\n    main()\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
Simple multiplexing example in Python3 <\/p>\n","protected":false},"author":193014733,"featured_media":564,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_coblocks_attr":"","_coblocks_dimensions":"","_coblocks_responsive_height":"","_coblocks_accordion_ie_support":"","advanced_seo_description":"","jetpack_seo_html_title":"","jetpack_seo_noindex":false,"jetpack_seo_schema_type":"","_jetpack_newsletter_access":"","_jetpack_dont_email_post_to_subs":false,"_jetpack_newsletter_tier_id":0,"_jetpack_memberships_contains_paywalled_content":false,"_wpcom_ai_launchpad_first_post":false,"_jetpack_hide_featured_image":false,"_jetpack_featured_image_duplicate_dismissed":0,"_jetpack_feature_clip_id":0,"_jetpack_memberships_contains_paid_content":false,"footnotes":"","jetpack_publicize_message":"","jetpack_publicize_feature_enabled":true,"jetpack_social_post_already_shared":false,"jetpack_social_options":{"image_generator_settings":{"template":"highway","default_image_id":0,"font":"","enabled":false},"version":2},"jetpack_post_was_ever_published":false},"categories":[775599553],"tags":[],"class_list":["post-509","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category--programming-and-algorithms"],"jetpack_publicize_connections":[],"jetpack_likes_enabled":true,"jetpack_sharing_enabled":true,"jetpack_shortlink":"https:\/\/wp.me\/pcmYUB-8d","jetpack-related-posts":[],"jetpack_featured_media_url":"https:\/\/i0.wp.com\/whalefallnotes.blog\/wp-content\/uploads\/2020\/11\/multiplexing-3.png?fit=841%2C421&ssl=1","_links":{"self":[{"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/posts\/509","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/users\/193014733"}],"replies":[{"embeddable":true,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/comments?post=509"}],"version-history":[{"count":17,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/posts\/509\/revisions"}],"predecessor-version":[{"id":608,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/posts\/509\/revisions\/608"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/media\/564"}],"wp:attachment":[{"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/media?parent=509"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/categories?post=509"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/whalefallnotes.blog\/zh\/wp-json\/wp\/v2\/tags?post=509"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}