Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package Server;
- import java.io.*;
- import java.net.ServerSocket;
- import java.net.Socket;
- import Client.Client.*;
- public class Server {
- public static void main(String[] args) {
- try {
- ServerSocket server = new ServerSocket(5555);
- while (true) {
- Socket serverSocket = server.accept();
- MyThread myThread = new MyThread(serverSocket);
- myThread.start();
- }
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- class MyThread extends Thread {
- private Socket serverSocket;
- public MyThread(Socket serverSocket) {
- this.serverSocket = serverSocket;
- }
- @Override
- public void run() {
- InputStream inputStream;
- DataOutputStream writeToSocket = null;
- BufferedReader readFromSocket = null;
- try {
- inputStream = serverSocket.getInputStream();
- final OutputStream outputStream;
- outputStream = serverSocket.getOutputStream();
- readFromSocket = new BufferedReader(new InputStreamReader(inputStream));
- writeToSocket = new DataOutputStream(outputStream);
- String line = null;
- while ((line = readFromSocket.readLine()) != null){
- System.out.println(line);
- if (line.equals("CZESC")) {
- writeToSocket.writeBytes("Hi\n");
- }
- if (line.equals("SEND")) {
- writeToSocket.writeBytes("OK\n");
- }
- }
- } catch (IOException e) {
- e.printStackTrace();
- } finally {
- try {
- readFromSocket.close();
- writeToSocket.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- }
Add Comment
Please, Sign In to add comment