본문으로 바로가기

채팅프로그램 리시버Receiver

category Programing/JAVA 2017. 11. 3. 18:49
반응형

package net.main;


import java.io.IOException;

import java.io.ObjectInputStream;

import java.util.Vector;


import object.shared.SPacket;

import object.shared.SRoom;


import ui.main.CMainPanel;


public class CReciver extends Thread{

private ObjectInputStream in;

private CMainPanel mainPanel;

public CReciver(ObjectInputStream in, CMainPanel mainPanel){

this.in = in;

this.mainPanel = mainPanel;

}

@SuppressWarnings("unchecked")

public void run(){

while(true){

SPacket packet = null;

try {

packet = (SPacket)in.readObject();

if(packet.getMessage().equals("connectionSuccess")){

mainPanel.setRoom((Vector<SRoom>)packet.getArgs()[0]);

mainPanel.writeMessage(packet.getMessage());

}else if(packet.getMessage().equals("setRoom")){

mainPanel.setRoom((Vector<SRoom>)packet.getArgs()[0]);

}else if(packet.getMessage().equals("enterRoom")){

mainPanel.enterRoom((SRoom)packet.getArgs()[0]);

}else if(packet.getMessage().equals("readMessage")){

mainPanel.writeMessage((String)packet.getArgs()[0]);

}

} catch (ClassNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

}


}







반응형