Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /**
- *
- * @author Sajmon
- */
- package src;
- import java.io.BufferedReader;
- import java.io.IOException;
- import java.io.InputStreamReader;
- import java.net.ServerSocket;
- import java.net.Socket;
- public class Server {
- private ServerSocket serverSocket;
- private Socket socket;
- private BufferedReader reader;
- public Server() {
- try {
- serverSocket = new ServerSocket(10001);
- System.out.println("Server is initialising...");
- }
- catch (IOException ex) { }
- }
- public void initConnection() {
- try {
- socket = serverSocket.accept(); // caka na pripojenie clienta, pokial sa klient nepripoji, caka sa na tomto riadku
- System.out.println("Connection with Client is created!");
- }
- catch (IOException ex) { }
- }
- public void readDataFromClient() throws IOException {
- String buffer;
- reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); // ziskam si InputStream pre citanie dat zo Socketu
- while (true) {
- buffer = reader.readLine(); // precita riadok zo Socketu
- System.out.println(buffer); // kontrolne ho vypisem
- if (buffer.equals("end")) {
- break;
- }
- }
- socket.close();
- }
- }
- /**
- * @author Sajmon
- */
- package src;
- import java.io.*;
- import java.net.Inet4Address;
- import java.net.Socket;
- import java.net.UnknownHostException;
- public class Client {
- private Socket socket;
- private PrintWriter output;
- private BufferedReader reader;
- public Client() {
- try {
- socket = new Socket(Inet4Address.getByName("localhost"), 10001);
- System.out.println("Client is initialising...");
- }
- catch (UnknownHostException ex) { }
- catch (IOException ex) { }
- }
- public void initConnection() {
- try {
- output = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()), true); // ziskam si OutputStream pre zapis dat na Socket a tieto data si bude Server tahat
- }
- catch (IOException ex) { }
- }
- public void sendDataToServer() throws IOException {
- reader = new BufferedReader(new InputStreamReader(System.in)); // citanie z klavesnice
- String buffer;
- while (true) {
- buffer = reader.readLine();
- output.println(buffer); // zapis riadku na Socket a odtial si ho bude Server tahat
- if (buffer.equals("end")) {
- break;
- }
- }
- socket.close();
- System.out.println("Server is stopped.");
- }
- }
- /**
- * @author Sajmon
- */
- package src;
- import java.io.IOException;
- public class Main {
- public static void main(String[] args) throws IOException {
- Server server = new Server();
- server.initConnection();
- server.readDataFromClient();
- /** Spustit v inom IDE **/
- //Client client = new Client();
- //client.initConnection();
- //client.sendDataToServer();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment