Advertisement
Guest User

Untitled

a guest
Oct 14th, 2019
79
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.45 KB | None | 0 0
  1. package dadsaclient;
  2.  
  3. import java.io.PrintWriter;
  4. import java.net.Socket;
  5. import java.util.Scanner;
  6.  
  7. // Server IP is 192.168.200.40
  8. public class DADSAClient {
  9.  
  10. public static void main(String[] args) throws Exception {
  11. if (args.length != 1) {
  12. System.out.println("Enter IP As Argument");
  13. return;
  14. }
  15. try (Socket socket = new Socket(args[0], 59898)) {
  16. System.out.println("Enter lines of text then Ctrl+D or Ctrl+C to quit");
  17. Scanner scanner = new Scanner(System.in);
  18. Scanner in = new Scanner(socket.getInputStream());
  19. PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
  20. while (scanner.hasNextLine()) {
  21. out.println(scanner.nextLine());
  22. System.out.println(in.nextLine());
  23. }
  24. }
  25. }
  26. }
  27. -----------------------
  28. package dadsaserver;
  29.  
  30. import java.io.IOException;
  31. import java.io.PrintWriter;
  32. import java.net.ServerSocket;
  33. import java.net.Socket;
  34. import java.util.Scanner;
  35. import java.util.concurrent.Executors;
  36. import java.util.concurrent.ExecutorService;
  37.  
  38. public class DADSAServer {
  39.  
  40. public static void main(String[] args) throws Exception {
  41. try (ServerSocket listener = new ServerSocket(59898)) {
  42. System.out.println("The DADSA server is running...");
  43. ExecutorService pool = Executors.newFixedThreadPool(20);
  44. while (true) {
  45. pool.execute(new Process(listener.accept()));
  46. }
  47. }
  48. }
  49.  
  50. private static class Process implements Runnable {
  51.  
  52. private Socket socket;
  53.  
  54. Process(Socket socket) {
  55. this.socket = socket;
  56. }
  57.  
  58. @Override
  59. public void run() {
  60. System.out.println("Connected: " + socket);
  61. try {
  62. Scanner in = new Scanner(socket.getInputStream());
  63. PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
  64. while (in.hasNextLine()) {
  65. out.println("Received OK: " + in.nextLine().toUpperCase());
  66. }
  67. } catch (Exception e) {
  68. System.out.println("Error: " + socket);
  69. } finally {
  70. try {
  71. socket.close();
  72. } catch (IOException e) {
  73. }
  74. System.out.println("Closed: " + socket);
  75. }
  76. }
  77. }
  78. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement