Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.io.BufferedReader;
- import java.io.BufferedWriter;
- import java.io.IOException;
- import java.io.InputStreamReader;
- import java.io.OutputStreamWriter;
- import java.net.Socket;
- import javafx.scene.control.TextArea;
- public class ClientHandler implements Runnable{
- private int portNumber;
- private BufferedWriter out;
- TextArea chatLog;
- Socket socket;
- ClientHandler(int portNumber, TextArea chatLog) {
- this.portNumber = portNumber;
- this.chatLog = chatLog;
- }
- @Override
- public void run() {
- try {
- socket = new Socket("localhost", portNumber);
- out = new BufferedWriter( new OutputStreamWriter(socket.getOutputStream()));
- BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
- while(true) {
- if(in.ready()) {
- chatLog.appendText(in.readLine());
- }
- }
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- //sends message to server
- public void sendToServer(String message) {
- try {
- out.write(message);
- out.flush();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- //closes connection to socket
- public void closeConnection() {
- try {
- socket.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement