WebSocket এবং API এর মাধ্যমে Real-time Data Transfer

Rails এবং WebSocket Integration - রুবি অন রেইল (Ruby on Rails) - Web Development

269

Real-time data transfer বা রিয়েল-টাইম ডেটা ট্রান্সফার এমন একটি প্রযুক্তি যা ব্যবহারকারীদের সাথে সার্ভারের সরাসরি, অবিচ্ছিন্ন এবং দ্রুত যোগাযোগ স্থাপন করতে সক্ষম। এটি বিশেষত চ্যাট অ্যাপ্লিকেশন, লাইভ আপডেট, গেমিং, এবং অন্যান্য ইন্টারঅ্যাকটিভ ওয়েব অ্যাপ্লিকেশনগুলির জন্য অত্যন্ত গুরুত্বপূর্ণ। WebSocket এবং API দুটি প্রধান প্রযুক্তি যা রিয়েল-টাইম ডেটা ট্রান্সফারের জন্য ব্যবহৃত হয়।

এই টিউটোরিয়ালে আমরা আলোচনা করবো WebSocket এবং API এর মাধ্যমে রিয়েল-টাইম ডেটা ট্রান্সফারের প্রযুক্তি, তাদের মধ্যে পার্থক্য এবং কিভাবে Ruby on Rails-এ এগুলো ব্যবহার করা যায়।

WebSocket: পরিচিতি

WebSocket একটি প্রোটোকল যা ক্লায়েন্ট এবং সার্ভারের মধ্যে একটানা, দ্বিমুখী যোগাযোগ তৈরি করে। এটি HTTP প্রোটোকল থেকে ভিন্ন এবং সার্ভার এবং ক্লায়েন্টের মধ্যে একটি স্টেবল কানেকশন স্থাপন করে, যা দীর্ঘ সময় ধরে কার্যকর থাকে।

WebSocket এর সুবিধা

দ্বিমুখী যোগাযোগ: WebSocket ক্লায়েন্ট এবং সার্ভারের মধ্যে উভয় দিকে ডেটা ট্রান্সফার করতে সক্ষম।
কম লেটেন্সি: একবার কানেকশন স্থাপিত হলে, তথ্য দ্রুত এবং কম লেটেন্সি সহ ট্রান্সফার করা সম্ভব।
স্টেটফুল কানেকশন: কানেকশন একটানা স্থায়ী থাকে, ফলে একটি নির্দিষ্ট কানেকশনের মাধ্যমে একাধিক মেসেজ আদান-প্রদান করা সম্ভব।

WebSocket এর ব্যবহার

WebSocket ব্যবহার করে রিয়েল-টাইম ডেটা ট্রান্সফার করা যায়, যেমন:

চ্যাট অ্যাপ্লিকেশন
স্টক মার্কেট ডেটা
লাইভ গেমিং
লাইভ শেয়ার মার্কেট আপডেট
পুশ নোটিফিকেশন

WebSocket এবং Ruby on Rails

Ruby on Rails-এ WebSocket ব্যবহারের জন্য ActionCable নামে একটি বিল্ট-ইন লাইব্রেরি রয়েছে। এটি WebSocket কানেকশন পরিচালনা করতে সাহায্য করে এবং ডেটার রিয়েল-টাইম আপডেট প্রদান করে।

ActionCable কে ব্যবহার করার জন্য:

ActionCable ইনস্টল করা:
Rails 5 এবং তার পরবর্তী ভার্সনগুলিতে ActionCable ডিফল্টভাবে অন্তর্ভুক্ত থাকে। ActionCable ব্যবহার শুরু করার জন্য আপনাকে কেবল নিচের কোডগুলি আপনার অ্যাপ্লিকেশন ফাইলে সংযুক্ত করতে হবে।
Channels তৈরি করা:
ActionCable এ WebSocket কানেকশন প্রতিষ্ঠিত করার জন্য একটি channel তৈরি করতে হয়। উদাহরণস্বরূপ:
```
rails generate channel chat
```
এটি app/channels/chat_channel.rb ফাইল তৈরি করবে। আপনি এখানে ক্লায়েন্ট এবং সার্ভারের মধ্যে ডেটা পাঠানোর জন্য কোড লিখতে পারেন।
```
# app/channels/chat_channel.rb
class ChatChannel < ApplicationCable::Channel
  def subscribed
    stream_from "chat_#{params[:room]}"
  end

  def unsubscribed
    # Clean up when the user unsubscribes
  end
end
```

Client-side JavaScript:
ক্লায়েন্ট সাইডে, আপনি JavaScript ব্যবহার করে WebSocket কানেকশন তৈরি করবেন:

// app/assets/javascripts/channels/chat.js
App.chat = App.cable.subscriptions.create({ channel: "ChatChannel", room: "General" }, {
  received: function(data) {
    console.log(data);
  }
});

Rails Server কনফিগারেশন:
আপনার config/cable.yml ফাইলে WebSocket কনফিগারেশন করতে হবে।

development:
  adapter: async
  url: redis://localhost:6379/1

production:
  adapter: redis
  url: redis://localhost:6379/1
  channel_prefix: your_app_production

API এর মাধ্যমে Real-time Data Transfer

API (Application Programming Interface) ব্যবহারের মাধ্যমে, বিশেষত RESTful API বা GraphQL API, আপনি রিয়েল-টাইম ডেটা ট্রান্সফার করতে পারেন, তবে এটি WebSocket এর তুলনায় একটু ভিন্ন ধরণের যোগাযোগ। API প্রোটোকলগুলো সাধারনত ক্লায়েন্ট-সার্ভার মডেলে কাজ করে, এবং এতে প্রতিটি রিকুয়েস্টের জন্য সার্ভারের কাছে একটি রেসপন্স প্রয়োজন হয়। তবে, API-এর মাধ্যমে রিয়েল-টাইম ডেটা পাওয়ার জন্য Polling, Long Polling, অথবা Server-Sent Events (SSE) ব্যবহার করা হয়।

API এবং Ruby on Rails

Rails এ API নির্মাণের জন্য আপনাকে Rails API mode ব্যবহার করতে হবে। এটি rails new কমান্ডের মাধ্যমে একটি API-ফোকাসড অ্যাপ্লিকেশন তৈরি করতে সহায়তা করে।

API রিসোর্স তৈরি করা:

একটি সাধারণ API রিসোর্স তৈরি করতে:

rails new myapp --api

এর পরে, একটি API কন্ট্রোলার তৈরি করতে:

rails generate controller Api::V1::Messages

কন্ট্রোলারে আপনি RESTful রিসোর্স মেথডগুলো যেমন index, create, show, update ইত্যাদি লিখতে পারেন।

class Api::V1::MessagesController < ApplicationController
  def index
    @messages = Message.all
    render json: @messages
  end

  def create
    @message = Message.new(message_params)
    if @message.save
      render json: @message, status: :created
    else
      render json: @message.errors, status: :unprocessable_entity
    end
  end

  private

  def message_params
    params.require(:message).permit(:content)
  end
end

Polling এবং Long Polling:
Polling হল একটি পদ্ধতি যেখানে ক্লায়েন্ট একটি নির্দিষ্ট সময় পর পর সার্ভারে রিকুয়েস্ট পাঠায়। যদি নতুন ডেটা থাকে, তবে তা রিটার্ন করা হয়, নতুবা সার্ভার একটি খালি রেসপন্স পাঠায়।
Long Polling হল একটি উন্নত পদ্ধতি যেখানে সার্ভার রিকুয়েস্ট গ্রহণ করার পর অপেক্ষা করে যতক্ষণ না নতুন ডেটা আসে, তারপর তা রিটার্ন করা হয়। এটি ক্লায়েন্টকে দ্রুত ডেটা দেয়, তবে এর কার্যকারিতা WebSocket-এর মতো নয়।
Server-Sent Events (SSE):
SSE একটি ওয়েব প্রযুক্তি যা ক্লায়েন্ট-সার্ভারের মধ্যে একমুখী রিয়েল-টাইম ডেটা ট্রান্সফার করার জন্য ব্যবহৃত হয়। এটি সাধারণত লাইভ ফিড, এলার্ট বা রিয়েল-টাইম অ্যাপ্লিকেশনগুলির জন্য ব্যবহৃত হয়।
```
# app/controllers/messages_controller.rb
class MessagesController < ApplicationController
  include ActionController::Live

  def stream
    response.headers['Content-Type'] = 'text/event-stream'
    10.times do |i|
      response.stream.write "data: Hello #{i}\n\n"
      sleep 1
    end
  ensure
    response.stream.close
  end
end
```
ক্লায়েন্ট সাইডে SSE রিসিভ করতে:
```
const eventSource = new EventSource('/messages/stream');
eventSource.onmessage = function(event) {
  console.log(event.data);
};
```