# 안드로이드 소켓 통신 (노트북 - 단말기)

^소켓: 컴퓨터의 특정 서비스와 통신하기 위해 지정하는 네트워크 주소 (IP , 포트번호)

^port: 컴퓨터 내 서비스를 지정하는 주소

^IP주소: 컴퓨터를 지정하는 주소 (0~255까지의 10진수 숫자 4개로 구성 됨 IPv4)

^peer to peer: 단말기 - 단말기 간 통신. 

^Server - Client: 서버가 존재해 서버를 통해 통신. ( <- Cursor)
    클라이언트가 서버에 인텐트를 보내면, 서버는 모든 클라이언트에 인텐트를 다시 보내줌.
    (단말기와 노트북 모두 같은 wifi를 사용해야 함.)
    (IP주소는 윈+R실행 / cmd / ipconfig / ipv4에서 확인)

#. 사용되는 중요 메소드 & 클래스

이 글은 "정보문화사 - 안드로이드 프로그래밍" 책을 참조하고 있습니다.

ChatServer 자바 프로젝트
- ChatServer.java
- ChatServerThread.java

• Soket 안드로이드 프로젝트
  - SoketEx.java

package kr.zlz.soket;

import android.os.Bundle;

import android.app.Activity;

import android.util.Log;

import android.view.Menu;

import android.app.AlertDialog;

import android.content.DialogInterface;

import android.graphics.Color;

import android.os.Handler;

import android.view.View;

import android.view.Window;

import android.widget.Button;

import android.widget.EditText;

import android.widget.RelativeLayout;

import android.widget.TextView;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

public class SocketEx extends Activity implements View.OnClickListener{

private final static String BR=System.getProperty("line.separator"); //개행

private final static String IP = "192.168.43.96" ; //IP주소 지정

private SocketEx current;

private TextView lblReceive;

private EditText edtSend;

private Button btnSend;

private Socket socket;

private InputStream in;

private OutputStream out;

private final Handler handler = new Handler();

private String txtReceive;

//초기화

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

requestWindowFeature(Window.FEATURE_NO_TITLE);

current = this;

RelativeLayout layout = new RelativeLayout(this);

layout.setBackgroundColor(Color.rgb(255, 255, 255));

setContentView(layout);

//수신 라벨의 생성

lblReceive = new TextView(this);

lblReceive.setId(1);

lblReceive.setText("");

//lblReceive.setTextScaleX(16.0f);

lblReceive.setTextColor(Color.rgb(0, 0, 0));

RelativeLayout.LayoutParams param1=//

new RelativeLayout.LayoutParams(500, 400);

lblReceive.setLayoutParams(param1);

layout.addView(lblReceive);

//송신 텍스트 박스의 생성

edtSend = new EditText(this);

edtSend.setId(2);

edtSend.setText("",TextView.BufferType.NORMAL);

RelativeLayout.LayoutParams param2=//

new RelativeLayout.LayoutParams(300,50);

param2.addRule(RelativeLayout.BELOW,1);

edtSend.setLayoutParams(param2);

layout.addView(edtSend);

//송신 버튼의 생성

btnSend = new Button(this);

btnSend.setText("송신");

btnSend.setOnClickListener(this);

RelativeLayout.LayoutParams param3=

new RelativeLayout.LayoutParams(200,50);

param3.addRule(RelativeLayout.BELOW,1);

param3.addRule(RelativeLayout.RIGHT_OF,2);

btnSend.setLayoutParams(param3);

layout.addView(btnSend);

//스레드 생성2

(new Thread() {public void run(){

try{

connect(IP,8080);

}

catch (Exception e) {

}

}

}).start();

}

private void connect (String ip, int port)

{

int size;

byte[] w = new byte[1024];

txtReceive ="";

try{

socket = new Socket(ip,port);

in = socket.getInputStream();

out = socket.getOutputStream();

while (socket != null && socket.isConnected())

{

size = in.read(w);

if (size <=0) continue;

txtReceive = new String(w,0,size,"UTF-8");

handler.post(new Runnable(){

public void run()

{

lblReceive.setText(lblReceive.getText() + txtReceive+BR);

}

});

}

} catch (Exception e){

Log.i("err", e.toString());

handler.post (new Runnable()

{

public void run()

{

SocketEx.showDialog(current,"","통신 에러입니다.1");

}

});

}

}

@Override

public boolean onCreateOptionsMenu(Menu menu) {

// Inflate the menu; this adds items to the action bar if it is present.

getMenuInflater().inflate(R.menu.main, menu);

return true;

}

@Override

public void onClick(View v) {

// TODO Auto-generated method stub

if (v ==btnSend)

{

try

{

if (socket !=null && socket.isConnected())

{

byte[] w = edtSend.getText().toString().getBytes("UTF8");

out.write(w);

out.flush();

edtSend.setText("",TextView.BufferType.NORMAL);

}

} catch (Exception e)

{

handler.post(new Runnable()

{

public void run()

{

SocketEx.showDialog(current,"","통신 에러입니다.2");

}

});

}

}

}

//대화상자 표시

public static void showDialog(final Activity activity, String title, String text)

{

AlertDialog.Builder ad = new AlertDialog.Builder(activity);

ad.setTitle(title);

ad.setMessage(text);

ad.setPositiveButton("OK", new DialogInterface.OnClickListener(){

public void onClick(DialogInterface dialog,int whichButton){

activity.setResult(Activity.RESULT_OK);

}

});

ad.create();

ad.show();

}

}

(2) 스레드의 생성 - 프로그램 실행 단위.
    - 여러 개의 처리를 동시에 실행하는 것이 가능해 짐.
    - Thread 클래스를 상속한 클래스가 Runnable 인터페이스를 정의한 객체에 Thread 객체를 생성하고 start() 메소드를 호출 함.
    - Override한 run() 메소드 내의 처리가 호출한 곳과는 다른 스레드로 실행되게 함.

(3) 소켓 접속 - 최초에 통신할 컴퓨터와 접속
    - Socket(String ip, int port) : ip주소와 port 번호를 반환
    - 입력스트림: getInputStream / 출력스트림: getOutputStream

(4) 수신 루프 - 소켓이 접속되어 있다면, 수신을 무한 반복하게 함.
    - boolean isConnected: 소켓 접속이 되어 있는지 여부 확인.

(5) 데이터 수신
     - 소켓 입력 스트림의 read() 메소드로 바이트 배열을 읽어 데이터를 수신합니다. read() 메소드를 호출하면, 소켓이 데이터를
        수신할 때까지 무한 대기하다가 데이터를 수신하면 수신한 데이터를 바이트 배열로 변환합니다. 이 프로그램에서는 크기가
        0 이상일 때에는 문자열로 변환해서 화면에 표시합니다.

(6) 핸들러에 의한 사용자 인터페이스 조작
    - Android의 사용자 인터페이스 (EditText등) 조작은 반드시 스레드 핸들러로부터 실행할 필요가 있습니다.
        해당 핸드럴 이외의 스레드로부터 조작하면 곤란해 집니다. 스레드를 스스로 생성하고 있으므로, 직접 조작이 불가능 함.
        그래서 자신이 사용할 주 스레드내의 핸들러도 스스로 생성하고, 핸들러를 통해 사용자 인터페이스를 조작하도록 함.
        Handler 객체를 생성한 후, Handler 클래스의 post() 메소드에 Runnable 인터페이스의 정의를 전달 합니다.

★★ Java프로젝트로 구성된 서버가 먼저 실행 되어야 동작이 가능 합니다. ★★