पाइथनमा zmq सँग काम गर्ने आधारभूत कुराहरू, एक साधारण कुञ्जी/मान भण्डार सिर्जना गर्दै

परिचय

साधारण कुञ्जी/मान भण्डारणको उदाहरण हेरौं, जस्तै मेमक्याच। यो सरल रूपमा डिजाइन गरिएको छ - डेटा मेमोरीमा भण्डार गरिएको छ, ह्याशम्याप संरचनामा। तिनीहरू एक tcp सकेट मार्फत पहुँच गरिन्छ। Python मा, hashmap एक नियमित डिक्ट हो। पहुँचको लागि हामी zeromq प्रयोग गर्नेछौं।

समायोजन

यो प्याकेज debian/ubuntu मा स्थापना गर्न, केवल कन्सोलमा प्रविष्ट गर्नुहोस्
sudo apt-get install libzmq-dev
sudo pip install zmq

कोड

हाम्रो सर्भरसँग काम गर्न कक्षा लेखौं:
प्रयोग गरिएको zmq सकेटको प्रकार REQ (अनुरोध, अनुरोध) हो, हामी अनुरोध पठाउँछौं र प्रतिक्रियाको लागि पर्खन्छौं।
नेटवर्कमा कुनै पनि प्रकारको डाटा भण्डारण र प्रसारण गर्न, हामी मानक अचार मोड्युल प्रयोग गर्छौं। काम "प्रोटोकल" तीन मानहरूको टुपल हो: (आदेश, कुञ्जी, डाटा)

import zmq
import pickle

class SuperCacher:
    def __init__(self):
        context = zmq.Context()
        self.socket = context.socket(zmq.REQ)
        self.socket.connect('tcp://127.0.0.1:43000')

    def get(self, key):
        self.socket.send(pickle.dumps(('get', key, None)))
        return pickle.loads(self.socket.recv())

    def set(self, key, data):
        self.socket.send(pickle.dumps(('set', key, data)))
        return self.socket.recv() == b'ok'

प्रयोग गर्नुहोस्

क्यास = सुपर क्याचर ()
cache.set('कुञ्जी', 'मान')
cache.get('कुञ्जी')

गृहकार्यको रूपमा, कक्षाको उदाहरण सिर्जना गर्दा ठेगाना/पोर्ट निर्दिष्ट गर्ने क्षमता थपेर कार्यान्वयन सुधार गर्नुहोस्।

अब सर्भर आफै लेखौं।
यस पटक सकेट REP(REPly, response) प्रयोग गरिएको छ - हामी अनुरोधको लागि पर्खिरहेका छौं, प्रतिक्रिया पठाउँदै। हामी अनुरोधलाई पार्स गर्छौं र लेखनको मामलामा 'ठीक छ', वा डेटाको साथ / पढ्ने अवस्थामा कुनै पनि होइन।

import pickle
import json
import zmq

def run_daemon():
    memory = {}

    context = zmq.Context()
    socket = context.socket(zmq.REP)
    socket.bind('tcp://127.0.0.1:43000')

    while True:
        try:
            command, key, data = pickle.loads(socket.recv())
            if command == 'set':
                memory[key] = data
                socket.send(b'ok')
            elif command == 'get':
                result = memory.get(key, None)
                socket.send(pickle.dumps(result))
        except Exception as e:
            print(e)

if __name__ == '__main__':
    run_daemon()

सबै कुरा सँगै परीक्षण गर्न, हामी आदेशको साथ सर्भर सुरु गर्छौं
python daemon.py

अर्को ट्याबमा, अन्तरक्रियात्मक मोडमा पाइथन सुरु गर्नुहोस्।

>>> from lib import SuperCacher
>>> cache=SuperCacher()
>>> cache.set('key', 'value')
True
>>> cache.get('key')
'value'

ओह चमत्कार, यो काम गर्दछ! अब तपाइँ सुरक्षित रूपमा तपाइँको पुन: सुरुमा "zmq प्रोटोकल प्रयोग गरेर कुञ्जी-मान भण्डारणको विकास" लेख्न सक्नुहुन्छ।

स्रोत: www.habr.com