Macket messenger

OWNER.md

@@ -0,0 +1 @@
+Макеев Иван Алексеевич, СА-11

src/main/java/track/lessons/lesson5generics/Cypher.java

@@ -1,10 +1,6 @@
 package track.lessons.lesson5generics;
 
-import java.util.Comparator;
-import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 import track.util.Util;
 
@@ -24,43 +20,60 @@ private Map<Character, Integer> readData(String data) {
                     ch += SYMBOL_DIST;
                 }
                 // Если это буква, то собираем частотную информацию
-
-
-
+                if (map.containsKey(ch)) {
+                    map.put(ch, map.get(ch) + 1);
+                } else {
+                    map.put(ch, 1);
+                }
             }
         }
         return map;
     }
 
-    /**
-    На вход приходит текст
-    1. Считываем readData() и получаем мапу {Символ -> Кол-во употреблений}
-    2. Далее нам нужно отсортировать пары ключ-значение по значению
-     (Называются{@code List<Map.Entry<Character, Integer>>})
-     (то есть по частоте употребления). Для этого можно создать список этих пар и отсортировать список.
-     У java.lang.List есть вспомогательный метод {@link List#sort(Comparator)}
-     Где Comparator - это логика сравнения объектов.
-
-     3. После того, как получен отсортированный список {@code List<Map.Entry<Character, Integer>>} нужно превратить его
-        обратно в Map для того, чтобы иметь быстрый доступ get().
-
+    /*
+     * На вход приходит текст
+     * 1. Считываем readData() и получаем мапу {Символ -> Кол-во употреблений}
+     * 2. Далее нам нужно отсортировать пары ключ-значение по значению
+     * (Называются{@code List<Map.Entry<Character, Integer>>})
+     * (то есть по частоте употребления). Для этого можно создать список этих пар и отсортировать список.
+     * У java.lang.List есть вспомогательный метод {@link List#sort(Comparator)}
+     * Где Comparator - это логика сравнения объектов.
+     * <p>
+     * 3. После того, как получен отсортированный список {@code List<Map.Entry<Character, Integer>>
+     * нужно превратить его
+     * обратно в Map для того, чтобы иметь быстрый доступ get().
      */
     public Map<Character, Integer> buildHist(String data) {
         Map<Character, Integer> map = readData(data);
-
-        return null;
+        List<Map.Entry<Character, Integer>> list = new ArrayList<>(map.entrySet());
+        list.sort((o1, o2) -> o2.getValue().compareTo(o1.getValue()));
+        LinkedHashMap<Character, Integer> hist = new LinkedHashMap<>();
+        for (Map.Entry<Character, Integer> entry : list) {
+            hist.put(entry.getKey(), entry.getValue());
+        }
+        System.out.println(hist);
+        return hist;
     }
 
     /**
      * Заменяем символы зашифрованного текста по таблицам частот
      *
-     * @param in - отсортированный по частоте алфавит для основного текста
-     * @param out - отсортированный по частоте алфавит для шифрованного текста
+     * @param in        - отсортированный по частоте алфавит для основного текста
+     * @param out       - отсортированный по частоте алфавит для шифрованного текста
      * @param encrypted - зашифрованный текст
      * @return расшифрованный текст
      */
     public String merge(List<Character> in, List<Character> out, String encrypted) {
-        return null;
+        StringBuilder decrypted = new StringBuilder();
+        for (int i = 0; i < encrypted.length(); i++) {
+            int idx = out.indexOf(encrypted.charAt(i));
+            if (idx >= 0) {
+                decrypted.append(in.get(idx));
+            } else {
+                decrypted.append(" ");
+            }
+        }
+        return decrypted.toString();
     }
 
     public static void main(String[] args) {
@@ -79,7 +92,4 @@ public static void main(String[] args) {
 
     }
 
-}
-
-
-
+}

src/main/java/track/lessons/lesson9/orm/UserDao.java

@@ -1,6 +1,5 @@
 package track.lessons.lesson9.orm;
 
-
 import java.util.List;
 import javax.persistence.EntityManager;
 import javax.persistence.PersistenceContext;

src/main/java/track/msgtest/messenger/mymessenger/BlockingQueue.java

@@ -0,0 +1,47 @@
+package track.msgtest.messenger.mymessenger;
+
+import java.util.Iterator;
+import java.util.LinkedList;
+
+public class BlockingQueue<E> {
+
+    private static final Object monitor = new Object();
+
+    private LinkedList<E> list = new LinkedList<>();
+
+    public synchronized void put(E elem) throws InterruptedException {
+        if (this.isEmpty()) {
+            notifyAll();
+        }
+        list.addLast(elem);
+    }
+
+    public synchronized E take() throws InterruptedException {
+        while (this.isEmpty()) {
+            try {
+                wait();
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
+        return list.removeFirst();
+    }
+
+    public boolean isEmpty() {
+        return list.size() == 0;
+    }
+
+    public int getSize() {
+        return list.size();
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder stringBuilder = new StringBuilder();
+        Iterator<E> iterator = list.iterator();
+        while (iterator.hasNext()) {
+            stringBuilder.append(iterator.next());
+        }
+        return new String(stringBuilder);
+    }
+}

src/main/java/track/msgtest/messenger/mymessenger/MyClient.java

@@ -0,0 +1,56 @@
+package track.msgtest.messenger.mymessenger;
+
+/**
+ * Created by ivan on 18.04.17.
+ */
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.Socket;
+import java.net.SocketException;
+import java.util.Scanner;
+
+public class MyClient {
+    private static final int BUFSIZE = 10;
+
+    public static void main(String[] args) throws IOException {
+        if (args.length < 1 || args.length > 2) {
+            throw new IllegalArgumentException("Parameters: <Server> <word> [<Port>]");
+        }
+
+        String server = args[0];
+
+        int servPort = (args.length == 2) ? Integer.parseInt(args[1]) : 7;
+
+        Socket socket = new Socket(server, servPort);
+        InputStream in = socket.getInputStream();
+        OutputStream out = socket.getOutputStream();
+
+        Thread outThread = new Thread() {
+            @Override
+            public void run() {
+                while (true) {
+                    // Считываем сообщение с консоли
+                    Scanner scanner = new Scanner(System.in);
+                    byte[] data = scanner.nextLine().getBytes();
+                    try {
+                        out.write(data);
+                    } catch (IOException ex) {
+                        ex.printStackTrace();
+                    }
+                }
+            }
+        };
+
+        outThread.start();
+
+        byte[] data = new byte[1024];
+        int bytesRcvd;
+
+        while ((bytesRcvd = in.read(data)) != -1) {
+            System.out.println("Received:" + new String(data).trim());
+            data = new byte[1024];
+        }
+        //socket.close();
+    }
+}

src/main/java/track/msgtest/messenger/mymessenger/MyServer.java

@@ -0,0 +1,57 @@
+package track.msgtest.messenger.mymessenger;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.net.SocketAddress;
+import java.util.Iterator;
+import java.util.LinkedList;
+
+public class MyServer {
+    private static final int BUFSIZE = 100;
+    private static LinkedList<OutputStream> outs = new LinkedList<>();
+    private static BlockingQueue<byte[]> recieveBufs = new BlockingQueue<>();
+
+    public static void main(String[] args) throws IOException {
+        if (args.length != 1) {
+            throw new IllegalArgumentException("Parameter: <Port>");
+        }
+        LinkedList<Integer> list = new  LinkedList<>();
+
+        int servPort = Integer.parseInt(args[0]);
+
+        ServerSocket serverSocket = new ServerSocket(servPort);
+
+        while (true) {
+            Socket clntSock = serverSocket.accept();
+            outs.addLast(clntSock.getOutputStream());
+
+            Thread inThread = new Thread() {
+                @Override
+                public void run() {
+                    try {
+                        int recvMsgSize;
+                        byte[] recieveBuf = new byte[BUFSIZE];
+
+                        SocketAddress clientAddress = clntSock.getRemoteSocketAddress();
+                        System.out.println("Handling client at " + clientAddress);
+
+                        InputStream in = clntSock.getInputStream();
+
+                        while ((recvMsgSize = in.read(recieveBuf)) != -1) {
+                            OutThread outThread = new OutThread(recvMsgSize, recieveBuf, outs);
+                            outThread.start();
+                        }
+                        clntSock.close();
+                    } catch (IOException ex) {
+                        ex.printStackTrace();
+                    }
+                }
+            };
+
+            inThread.start();
+        }
+    }
+}

src/main/java/track/msgtest/messenger/mymessenger/OutThread.java

@@ -0,0 +1,33 @@
+package track.msgtest.messenger.mymessenger;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.LinkedList;
+
+/**
+ * Created by ivan on 22.04.17.
+ */
+public class OutThread extends Thread {
+
+    int recvMsgSize;
+    byte[] recieveBuf;
+    LinkedList<OutputStream> outs;
+
+    public OutThread( int recvMsgSize, byte[] recieveBuf, LinkedList<OutputStream> outs ) {
+        this.recvMsgSize = recvMsgSize;
+        this.recieveBuf = recieveBuf;
+        this.outs = outs;
+    }
+
+    @Override
+    public void run() {
+        try {
+            for (OutputStream out : outs) {
+                out.write(recieveBuf, 0, recvMsgSize );
+                out.flush();
+            }
+        } catch (IOException ex) {
+            ex.printStackTrace();
+        }
+    }
+}