Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package fr.crafttim.chat.client.network;
- import java.io.BufferedReader;
- import java.io.IOException;
- import java.io.InputStreamReader;
- import java.io.PrintStream;
- import java.net.InetSocketAddress;
- import java.net.Socket;
- import fr.crafttim.chat.client.ChatClient;
- public class ClientSide implements Runnable{
- private ChatClient chatClient;
- private Socket socket;
- private PrintStream ps;
- private BufferedReader br;
- private boolean running = false;
- public ClientSide(ChatClient chatClient){
- this.chatClient = chatClient;
- }
- public boolean connect(String ip, int port, String name){
- try {
- socket = new Socket();
- InetSocketAddress adress = new InetSocketAddress(ip, port);
- socket.connect(adress);
- if(socket.isConnected()){
- br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
- ps = new PrintStream(socket.getOutputStream());
- ps.println(name);
- ps.flush();
- }
- return true;
- } catch (Exception e) {
- }
- return false;
- }
- private String read(){
- try {
- if(br.ready()){
- return br.readLine();
- }
- } catch (IOException e) {
- e.printStackTrace();
- }
- return null;
- }
- public void write(String line){
- ps.println(line);
- ps.flush();
- }
- public void start(){
- Thread t = new Thread(this);
- running = true;
- t.start();
- }
- @Override
- public void run() {
- String ln = null;
- while (running) {
- ln = read();
- if(ln != null){
- chatClient.getWindow().postLine(ln);
- ln = null;
- }
- try {
- Thread.sleep(25);
- } catch(Exception e) {
- }
- }
- }
- }
Add Comment
Please, Sign In to add comment