ソースを参照

tcp 양방향

tobby48 5 年 前
コミット
2e6119c6a4
共有2 個のファイルを変更した94 個の追加0 個の削除を含む
  1. 45
    0
      src/kr/co/swh/lecture/network/tcp/TcpClientResponse.java
  2. 49
    0
      src/kr/co/swh/lecture/network/tcp/TcpServerRequest.java

+ 45
- 0
src/kr/co/swh/lecture/network/tcp/TcpClientResponse.java ファイルの表示

@@ -0,0 +1,45 @@
1
+package kr.co.swh.lecture.network.tcp; 
2
+
3
+import java.io.BufferedReader;
4
+import java.io.InputStreamReader;
5
+import java.net.Socket;
6
+
7
+/**
8
+ * <pre>
9
+ * kr.co.swh.lecture.network.tcp
10
+ * TcpClientResponse.java
11
+ *
12
+ * 설명 :TCP 클라이언트
13
+ * </pre>
14
+ * 
15
+ * @since : 2018. 6. 23.
16
+ * @author : tobby48
17
+ * @version : v1.0
18
+ */
19
+public class TcpClientResponse {
20
+	public static void main(String[] args) {
21
+		Socket sock = null;		// 서버에 접속할 소켓 변수
22
+		try{
23
+			// 서버 연결
24
+			sock = new Socket("127.0.0.1", 9999);
25
+			// 서버에 메세지 전송
26
+//			PrintWriter out = new PrintWriter(sock.getOutputStream()); // 테이터를 전송할  Write 변수
27
+//			out.println("SWHAcademy\n");
28
+//			out.flush();
29
+			
30
+//			BufferedWriter w = new BufferedWriter(new OutputStreamWriter(sock.getOutputStream()));
31
+//			w.write("SWHAcademy\n");
32
+//			w.close();
33
+			
34
+			BufferedReader w = new BufferedReader(new InputStreamReader(sock.getInputStream()));
35
+			System.out.println(w.readLine());
36
+			w.close();
37
+			
38
+			// 접속 끊기
39
+			sock.close();
40
+		}catch(Exception e){
41
+			System.out.println(e.getMessage());
42
+		}
43
+
44
+	}
45
+}

+ 49
- 0
src/kr/co/swh/lecture/network/tcp/TcpServerRequest.java ファイルの表示

@@ -0,0 +1,49 @@
1
+package kr.co.swh.lecture.network.tcp; 
2
+
3
+import java.io.BufferedWriter;
4
+import java.io.OutputStreamWriter;
5
+import java.net.ServerSocket;
6
+import java.net.Socket;
7
+
8
+/**
9
+ * <pre>
10
+ * kr.co.swh.lecture.network.tcp
11
+ * TcpServerRequest.java
12
+ *
13
+ * 설명 :TCP 서버
14
+ * </pre>
15
+ * 
16
+ * @since : 2018. 6. 23.
17
+ * @author : tobby48
18
+ * @version : v1.0
19
+ */
20
+public class TcpServerRequest {
21
+	public static void main(String[] args) {
22
+		ServerSocket ss = null;		// 서버소켓 변수
23
+		Socket sock = null;		// 접속할 클라이언트 소켓변수
24
+		try {
25
+			ss = new ServerSocket(9999);	// 서버소켓생성
26
+			System.out.println("서버 대기중 ");
27
+			while (true) {
28
+				// 클라이언트가 접속 할때까지 대기하다가 접속하면 socket생성
29
+				sock = ss.accept();
30
+				System.out.println("접속자 정보 : " + sock);
31
+				
32
+//				// 클라이언트에서 보낸 한줄의 메시지를 출력
33
+//				BufferedReader in = new BufferedReader(new InputStreamReader(sock.getInputStream()));
34
+//				String msg = in.readLine();
35
+//				System.out.println("보낸 메시지 : "+msg);
36
+				
37
+				// 클라이언트에서 보낸 한줄의 메시지를 출력
38
+				BufferedWriter in = new BufferedWriter(new OutputStreamWriter(sock.getOutputStream()));
39
+				in.write("haha");
40
+				
41
+				//클라이언트와의 연결 끊기
42
+				in.close();
43
+				sock.close();
44
+			}
45
+		} catch (Exception e) {
46
+			System.out.println(e.getMessage());
47
+		}
48
+	}
49
+}