Am trying to create a Network Topology simulation,wherein I need to write/read as part of the requirement.
The rough sketch of the program is like below.
Class Writer implements Runnable
{
pubic void write(Socket socket)
{
Thread t1 = new Thread();
t1.start();
Reader reader = new Reader();
reader.read(socket);
}
public void run()
{
DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
dos.writeUTF("DATA1");
dos.writeChars("009 From Socket No: "+temp.toString());
dos.flush();
PrintWriter a = new PrintWriter(socket.getOutputStream());
a.write("DATA2");
a.println("DATA3");
a.flush();
}
}
class Reader implements Runnable
{
public void read(Socket socket){
Thread t1 = new Thread();
t1.start();
}
public void run(){
DataInputStream dis = new DataInputStream(socket.getInputStream());
InputStream inputFromSocket = socket.getInputStream();
BufferedReader streamReader = new BufferedReader(new InputStreamReader(inputFromSocket));
String strTemp1 = streamReader.readLine();
System.out.println("gk"+dis.available());
while(true){
if(strTemp!=null)
{
System.out.println("DATA from I/P Stream"+strTemp);
}
if(dis.available!=null){
System.out.println("DATA from Datat I/P Stream"+dis.available());
}
}
}
The rough sketch of the program is like below.
Class Writer implements Runnable
{
pubic void write(Socket socket)
{
Thread t1 = new Thread();
t1.start();
Reader reader = new Reader();
reader.read(socket);
}
public void run()
{
DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
dos.writeUTF("DATA1");
dos.writeChars("009 From Socket No: "+temp.toString());
dos.flush();
PrintWriter a = new PrintWriter(socket.getOutputStream());
a.write("DATA2");
a.println("DATA3");
a.flush();
}
}
class Reader implements Runnable
{
public void read(Socket socket){
Thread t1 = new Thread();
t1.start();
}
public void run(){
DataInputStream dis = new DataInputStream(socket.getInputStream());
InputStream inputFromSocket = socket.getInputStream();
BufferedReader streamReader = new BufferedReader(new InputStreamReader(inputFromSocket));
String strTemp1 = streamReader.readLine();
System.out.println("gk"+dis.available());
while(true){
if(strTemp!=null)
{
System.out.println("DATA from I/P Stream"+strTemp);
}
if(dis.available!=null){
System.out.println("DATA from Datat I/P Stream"+dis.available());
}
}
}