Mediator Pattern

-

Mediator Pattern

A Mediator Pattern says that “to define an object that encapsulates how a set of objects interact”.

I will explain the Mediator pattern by considering a problem. When we begin with development, we have a few classes and these classes interact with each other producing results. Now, consider slowly, the logic becomes more complex when functionality increases. Then what happens? We add more classes and they still interact with each other but it gets really difficult to maintain this code now. So, Mediator pattern takes care of this problem.

Mediator pattern is used to reduce communication complexity between multiple objects or classes. This pattern provides a mediator class which normally handles all the communications between different classes and supports easy maintainability of the code by loose coupling.

Benefits:

    • It decouples the number of classes.
    • It simplifies object protocols.
    • It centralizes the control.
    • The individual components become simpler and much easier to deal with because they don’t need to pass messages to one another.

The components don’t need to contain logic to deal with their intercommunication and therefore, they are more generic.

 

USAGE:

  • It is commonly used in message-based systems likewise chat applications.
  • When the set of objects communicate in complex but in well-defined ways.

UML for Mediator Pattern:

Mediator Pattern

Participants:

  • ApnaChatroom :- defines the interface for interacting with participants.
  • ApnaChatroomImpl :- implements the operations defined by the Chatroom interface. The operations are managing the interactions between the objects: when one participant sends a message, the message is sent to the other participants.
  • Participant :- defines an interface for the users involved in chatting.
  • User1, User2, …UserN :- implements Participant interface; the participant can be a number of users involved in chatting. But each Participant will keep only a reference to the ApnaChatRoom.
Implementation of Mediator Pattern:

Step 1:

Create a ApnaChatRoom interface.

//This is an interface.  

public interface ApnaChatRoom {

  public void showMsg(String msg, Participant p);

}// End of the ApnaChatRoom interface.

Step 2:

Create a ApnaChatRoomIml class that will implement ApnaChatRoom interface and will also use the number of participants involved in chatting through Participant interface.

//This is a class.  

import java.text.DateFormat;

import java.text.SimpleDateFormat;

import java.util.Date;

public class ApnaChatRoomImpl implements ApnaChatRoom {

// get current date time

DateFormat dateFormat = new SimpleDateFormat(“E dd-MM-yyyy hh:mm a”);

Date date = new Date();

@Override

public void showMsg(String msg, Participant p) {

System.out.println(p.getName() + “‘gets message: ” + msg);

System.out.println(“\t\t\t\t” + “[“ + dateFormat.format(date).toString() + “]”);

}

}// End of the ApnaChatRoomImpl class.

Step 3:

Create a Participant abstract class.

//This is an abstract class.  

public abstract class Participant {

 public abstract void sendMsg(String msg);

 public abstract void setname(String name);

 public abstract String getName();

}// End of the Participant abstract class.

 

Step 4:

Create a User1 class that will extend Participant abstract class and will use the ApnaChatRoom interface.

//This is a class.  

public class User1 extends Participant {

privateString name;

private ApnaChatRoom chat;

@Override

publicvoidsendMsg(String msg) {

chat.showMsg(msg, this);

}

@Override

publicvoidsetname(String name) {

this.name = name;

}

@Override

public String getName() {

returnname;

}

public User1(ApnaChatRoom chat) {

this.chat = chat;

}

}// End of the User1 class.

Step 5:

Create a User2 class that will extend Participant abstract class and will use the ApnaChatRoom interface.

public class User2 extends Participant {

privateString name;

private ApnaChatRoom chat;

@Override

publicvoidsendMsg(String msg) {

this.chat.showMsg(msg, this);

}

@Override

publicvoidsetname(String name) {

this.name = name;

}

@Override

public String getName() {

returnname;

}

public User2(ApnaChatRoom chat) {

this.chat = chat;

}

}

// End of the User2 class. 

Step 6:

Create a MediatorPatternDemo class that will use participants involved in chatting.

//This is a class.  

public class MediatorPatternDemo {

publicstaticvoidmain(String args[]) {

ApnaChatRoom chat = new ApnaChatRoomImpl();

User1 u1 = new User1(chat);

u1.setname(“Ashwani Rajput”);

u1.sendMsg(“Hi Ashwani! how are you?”);

User2 u2 = new User2(chat);

u2.setname(“Soono Jaiswal”);

u2.sendMsg(“I am Fine ! You tell?”);

}

}// End of the MediatorPatternDemo class.

Mediator Pattern

 

Popular posts from this blog

Window function in PySpark with Joins example using 2 Dataframes (inner join)

-
Input details: #● File has json records #● Each record has fields: #○ user_id #○ card_num #○ merchant #○ category #○ amount #○ ts ### Below analysis to be done Sample data: +------+--------+---------+--------+----------+-------+|amount|card_num| category|merchant| ts|user_id|+------+--------+---------+--------+----------+-------+| 243| C_108| food| M_102|1579532902| U_104|| 699| C_106|cosmetics| M_103|1581759040| U_103|| 228| C_104| children| M_110|1584161986| U_103| Solution: from pyspark.sql.functions import col # this can be done without using window function creditCardData = spark.read.json(“card_transactions.json”) useridMaxSpendDF = df.groupby(‘user_id’).max(‘amount’) useridMaxSpendDF=useridMaxSpendDF.withColumnRenamed(“max(amount)”,”max_amount”) useridMaxSpendDF=useridMaxSpendDF.withColumnRenamed(“user_id”,”m_user_id”) cond = [creditCardData.user_id == useridMaxSpen...
Read more

Complex SQL: fetch the users who logged in consecutively 3 or more times (lead perfect example)

-
From the login_details table, fetch the users who logged in consecutively 3 or more times. Table Name : LOGIN_DETAILS Approach : We need to fetch users who have appeared 3 or more times consecutively in login details table. There is a window function which can be used to fetch data from the following record. Use that window function to compare the user name in current row with user name in the next row and in the row following the next row. If it matches then fetch those records. –Table Structure: drop table login_details; create table login_details( login_id int primary key, user_name varchar(50) not null, login_date date); delete from login_details; insert into login_details values (101, ‘Michael’, current_date), (102, ‘James’, current_date), (103, ‘Stewart’, current_date+1), (104, ‘Stewart’, current_date+1), (105, ‘Stewart’, current_date+1), (106, ‘Michael’, current_date+2), (107, ‘Michael’, cur...
Read more

Credit Card Data Analysis using PySpark (how to use auto broadcast join after disabling it)

-
Input details: #● File has json records #● Each record has fields: #○ user_id #○ card_num #○ merchant #○ category #○ amount #○ ts ### Below analysis to be done Sample data: +------+--------+---------+--------+----------+-------+|amount|card_num| category|merchant| ts|user_id|+------+--------+---------+--------+----------+-------+| 243| C_108| food| M_102|1579532902| U_104|| 699| C_106|cosmetics| M_103|1581759040| U_103|| 228| C_104| children| M_110|1584161986| U_103| Application: Here we will disable auto broadcast and then join 2 data frames and will see execution plan which should use broadcast join Solution: from pyspark.sql import SparkSession from pyspark.sql.functions import broadcast spark = SparkSession.builder.master(‘local[2]’)\ .appName(‘RDD_Methods_Examples’)\ .getOrCreate() print(spark.conf.get(“spark.sql.autoBroadcastJoinThreshold”)) spark.conf.set(“spark.sql.autoBroadcastJoinThreshold”, -1) pr...
Read more