Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package Quiz_Server;
- import java.io.IOException;
- import java.io.ObjectInputStream;
- import java.io.ObjectOutputStream;
- import java.net.Socket;
- import java.util.ArrayList;
- import java.util.List;
- import quiz.MysqlConnection;
- import tools.User;
- public class ServerThread extends Thread {
- private MysqlConnection connection;
- Socket socket = null;
- ObjectInputStream objectInputStream ;
- ObjectOutputStream objectOutputSteam;
- boolean isConnected=false;
- ServerThread(Socket socket){
- this.socket=socket;
- isConnected=true;
- try {
- objectInputStream = new ObjectInputStream(socket.getInputStream());
- objectOutputSteam = new ObjectOutputStream(socket.getOutputStream());
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- public void sendResult(List<String> executeresult ) {
- try {
- objectOutputSteam.writeObject(executeresult);
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- public List<String> execute(String exec){
- List<String> result = new ArrayList<String>();
- switch (exec) {
- case "user_list":
- for(User user : connection.getUsers()){
- result.add(user.getName());
- }
- break;
- default:
- break;
- }
- return result;
- }
- public String getMessage(){
- String message=null;
- try {
- message = (String) objectInputStream.readObject();
- } catch (ClassNotFoundException e) {
- e.printStackTrace();
- } catch (IOException e) {
- e.printStackTrace();
- }
- return message;
- }
- public void run()
- {
- while(isConnected){
- String message = getMessage();
- sendResult(execute(message));
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement