Java program to implement broadcast

Server (broads.java)
import java.io.*;
import java.net.*;
import java.lang.*;
class broads implements Runnable
{
int i=0,j=0;
ServerSocket ser;
Thread t1=null,t2=null;
PrintWriter pw;
String msg;
Socket sl[]=new Socket[20];
BufferedReader br;
public broads()
{
try
{
ser=new ServerSocket(8000);
System
br=new BufferedReader(new InputStreamReader(System.in));
}
catch(Exception e)
{
System.out.println(e);
}
}
public void run()
{
if(Thread.currentThread()==t1)
{
try
{
for(;;)
{
i++;
sl[i]=ser.accept();
System.out.println("Client"+i+" connected");
}
}
catch(Exception e)
{
System.out.println("Client not connected");
}}
else
{
try
{
do
{
msg=br.readLine();
for(j=1;j<i;j++)
{
pw=new PrintWriter(sl[j].getOutputStream(),true);
pw.println(msg);
}
}
while(!msg.equals("q"));
}
catch(Exception e)
{
System.out.println(e);
}
}
System.exit(0);
}
public static void main(String args[])
{
System.out.println("Server started\n");
broads ob=new broads();
ob.t1=new Thread(ob);
ob.t2=new Thread(ob);
ob.t1.start();
ob.t2.start();
}
}

Client (broadc.java)
import java.io.*;
import java.net.*;
class broadc
{
public static void main(String args[])
{
String recieveMessage;
Socket s;
BufferedReader recieveRead;
try
{
s=new Socket("127.0.0.1",8000);
System.out.println("Connected");
do
{
recieveRead=new BufferedReader(new InputStreamReader(s.getInputStream()));
recieveMessage=recieveRead.readLine();
System.out.println("Recieved data: "+recieveMessage);
}
while(!recieveMessage.equals("q"));
}
catch(Exception e)
{
}
}
}