Flask-SocketIO একটি শক্তিশালী এক্সটেনশন যা Flask অ্যাপ্লিকেশনকে WebSocket প্রটোকল ব্যবহার করে দুই-দিকে (bidirectional) যোগাযোগ সক্ষম করে। এটি ক্লায়েন্ট এবং সার্ভারের মধ্যে লাইভ, রিয়েল-টাইম যোগাযোগ নিশ্চিত করে, যা চ্যাট অ্যাপ্লিকেশন, লাইভ আপডেট, গেম, এবং আরও অনেক ধরনের ওয়েব অ্যাপ্লিকেশনের জন্য উপযোগী।
Flask-SocketIO এর মাধ্যমে, আপনি Flask অ্যাপ্লিকেশনগুলিতে WebSocket কানেকশন তৈরি করতে পারেন এবং events হ্যান্ডল করতে পারেন। এখানে আমরা Flask-SocketIO ব্যবহার করে WebSocket এন্ডপয়েন্ট তৈরি করার পদ্ধতি দেখাবো।
১. Flask-SocketIO ইনস্টলেশন
প্রথমে Flask-SocketIO এক্সটেনশনটি ইনস্টল করতে হবে:
pip install flask-socketio
এটি Flask অ্যাপ্লিকেশনে WebSocket সমর্থন যোগ করবে।
২. Flask-SocketIO সেটআপ
এখন Flask অ্যাপ্লিকেশন তৈরি করুন এবং Flask-SocketIO এর মাধ্যমে WebSocket কনফিগার করুন।
উদাহরণ:
from flask import Flask, render_template
from flask_socketio import SocketIO, send
app = Flask(__name__)
# Flask-SocketIO সেটআপ
socketio = SocketIO(app)
# হোম পেজ রাউট
@app.route('/')
def index():
return render_template('index.html')
# WebSocket এর মাধ্যমে মেসেজ পাঠানো
@socketio.on('message')
def handle_message(msg):
print('Message received: ' + msg)
send("Echo: " + msg, broadcast=True) # ক্লায়েন্টকে ইকো মেসেজ পাঠানো
# WebSocket কানেকশন তৈরি হওয়া
@socketio.on('connect')
def handle_connect():
print("Client connected")
send("Connected to WebSocket server", broadcast=True)
# WebSocket ডিসকানেকশন
@socketio.on('disconnect')
def handle_disconnect():
print("Client disconnected")
if __name__ == '__main__':
socketio.run(app, debug=True)
এখানে:
SocketIO(app): Flask অ্যাপ্লিকেশনটি SocketIO ইনস্ট্যান্সে পাস করা হয়েছে।@socketio.on('message'): এটি একটি WebSocket event হ্যান্ডলারের উদাহরণ, যেখানে মেসেজ পেলে সেটি প্রসেস করা হয় এবংsend()ফাংশনের মাধ্যমে ক্লায়েন্টে পাঠানো হয়।@socketio.on('connect'): যখন ক্লায়েন্ট কানেক্ট হয়, তখন এটি হ্যান্ডল হয় এবং একটি মেসেজ পাঠানো হয়।@socketio.on('disconnect'): যখন ক্লায়েন্ট ডিসকানেক্ট হয়, তখন এটি হ্যান্ডল হয় এবং একটি মেসেজ লগ করা হয়।
৩. Client Side (HTML + JavaScript)
WebSocket এর মাধ্যমে Flask-SocketIO কনফিগার করার পর, ক্লায়েন্ট সাইডে WebSocket কানেকশন তৈরি করতে হবে। আপনি JavaScript দিয়ে WebSocket কানেকশন করতে পারবেন এবং Flask এর সাথে যোগাযোগ করতে পারবেন।
templates/index.html:
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>Flask WebSocket Example</title>
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/4.0.1/socket.io.min.js"></script>
</head>
<body>
<h1>WebSocket Test</h1>
<div id="messages"></div>
<input type="text" id="messageInput" placeholder="Type a message">
<button onclick="sendMessage()">Send</button>
<script>
// WebSocket কানেকশন তৈরি
var socket = io.connect('http://' + document.domain + ':' + location.port);
// সাইন ইন হলে মেসেজ গ্রহণ করা
socket.on('message', function(msg) {
var messagesDiv = document.getElementById("messages");
messagesDiv.innerHTML += '<p>' + msg + '</p>';
});
// মেসেজ পাঠানো
function sendMessage() {
var message = document.getElementById("messageInput").value;
socket.send(message);
document.getElementById("messageInput").value = ''; // ইনপুট ফিল্ড খালি করা
}
</script>
</body>
</html>
এখানে:
socket.on('message'): এটি ক্লায়েন্টে মেসেজ গ্রহণ করার জন্য ব্যবহৃত হয়, যা Flask থেকে আসবে।socket.send(message): এটি WebSocket এর মাধ্যমে Flask সার্ভারে মেসেজ পাঠানোর জন্য ব্যবহৃত হয়।
৪. Flask-SocketIO Events এবং Broadcasting
Flask-SocketIO এর মাধ্যমে আপনি বিভিন্ন ইভেন্ট হ্যান্ডল করতে পারবেন এবং broadcasting করতে পারবেন। উপরের কোডে send("Echo: " + msg, broadcast=True) ব্যবহৃত হয়েছে, যা মেসেজ ক্লায়েন্টে পাঠানোর পরে সকল কানেক্টেড ক্লায়েন্টকে মেসেজটি পাঠিয়ে দিবে।
Broadcasting Example:
@socketio.on('message')
def handle_message(msg):
print('Message received: ' + msg)
send(msg, broadcast=True) # সকল কানেক্টেড ক্লায়েন্টকে মেসেজ পাঠানো
এখানে:
broadcast=True: এটি Flask-SocketIO কে নির্দেশ দেয় যে মেসেজটি সমস্ত কানেক্টেড ক্লায়েন্টদের কাছে পাঠানো হবে।
৫. Flask-SocketIO Scalability
Flask-SocketIO সহজেই scalable হয় যখন এটি Redis অথবা RabbitMQ এর মতো মেসেজ ব্রোকারের সাথে ব্যবহৃত হয়। এটি ক্লাস্টারড অ্যাপ্লিকেশনে সহায়ক হতে পারে, যেখানে বিভিন্ন সার্ভার একে অপরের সাথে মেসেজ শেয়ার করতে পারে।
Redis এর সাথে Flask-SocketIO কনফিগারেশন উদাহরণ:
pip install redis
এবং Flask অ্যাপে Redis ব্যবহার করার জন্য:
from flask_socketio import SocketIO
from redis import Redis
app = Flask(__name__)
# Redis কানেকশন এবং Flask-SocketIO সেটআপ
socketio = SocketIO(app, message_queue='redis://localhost:6379/0')
এখানে, message_queue Redis এর URI নির্দেশ করে যেখানে SocketIO মেসেজ কিউ পরিচালনা করবে।
৬. Flask-SocketIO Debugging
Flask-SocketIO ডিবাগিং মোডে অ্যাপ চালানোর সময় যদি কোনো সমস্যা হয়, আপনি debug=True প্যারামিটার ব্যবহার করতে পারেন:
socketio.run(app, debug=True)
এটি Flask এবং SocketIO উভয়ের জন্য ডিবাগিং সক্রিয় করবে এবং ত্রুটি সনাক্ত করার সময় সহায়ক হবে।
Flask-SocketIO দিয়ে WebSocket endpoints তৈরি করা খুবই সহজ এবং কার্যকরী। এটি ক্লায়েন্ট এবং সার্ভারের মধ্যে লাইভ, রিয়েল-টাইম যোগাযোগ সক্ষম করে, যা বিভিন্ন রিয়েল-টাইম অ্যাপ্লিকেশনের জন্য ব্যবহৃত হয়। SocketIO events এবং broadcasting সুবিধার মাধ্যমে আপনি ইন্টারেক্টিভ এবং ডাইনামিক অ্যাপ্লিকেশন তৈরি করতে পারেন। Flask-SocketIO এর সাহায্যে আপনি চ্যাট অ্যাপ, লাইভ আপডেট, গেম এবং অন্যান্য রিয়েল-টাইম সার্ভিস তৈরি করতে পারবেন।
