Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package dadsaclient;
- import java.io.PrintWriter;
- import java.net.Socket;
- import java.util.Scanner;
- // Server IP is 192.168.200.40
- public class DADSAClient {
- public static void main(String[] args) throws Exception {
- if (args.length != 1) {
- System.out.println("Enter IP As Argument");
- return;
- }
- try (Socket socket = new Socket(args[0], 59898)) {
- System.out.println("Enter lines of text then Ctrl+D or Ctrl+C to quit");
- Scanner scanner = new Scanner(System.in);
- Scanner in = new Scanner(socket.getInputStream());
- PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
- while (scanner.hasNextLine()) {
- out.println(scanner.nextLine());
- System.out.println(in.nextLine());
- }
- }
- }
- }
- -----------------------
- package dadsaserver;
- import java.io.IOException;
- import java.io.PrintWriter;
- import java.net.ServerSocket;
- import java.net.Socket;
- import java.util.Scanner;
- import java.util.concurrent.Executors;
- import java.util.concurrent.ExecutorService;
- public class DADSAServer {
- public static void main(String[] args) throws Exception {
- try (ServerSocket listener = new ServerSocket(59898)) {
- System.out.println("The DADSA server is running...");
- ExecutorService pool = Executors.newFixedThreadPool(20);
- while (true) {
- pool.execute(new Process(listener.accept()));
- }
- }
- }
- private static class Process implements Runnable {
- private Socket socket;
- Process(Socket socket) {
- this.socket = socket;
- }
- @Override
- public void run() {
- System.out.println("Connected: " + socket);
- try {
- Scanner in = new Scanner(socket.getInputStream());
- PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
- while (in.hasNextLine()) {
- out.println("Received OK: " + in.nextLine().toUpperCase());
- }
- } catch (Exception e) {
- System.out.println("Error: " + socket);
- } finally {
- try {
- socket.close();
- } catch (IOException e) {
- }
- System.out.println("Closed: " + socket);
- }
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement