안드로이드 - 소켓통신

출처: http://webprogrammer.tistory.com/1815

출처는 명확하지 않음-_-;; 원작성자 분에게는 죄송합니다;
앞의 2009/03/10 - [Computer Science/Android] - [펌]Android에서의 TCP/IP 통신 글의 코드와 매우 유사하긴 하지만.. 뭔가 더 간단하고 예제는 많을 수록 좋으므로;(-_-)

SocketTest.java 

안드로이드 - DB file을 assets디렉토리에서 폰으로 복사 이동하는 예제

원본출처: http://blog.daum.net/dayhyub/53

 안드로이드 개발시 종목기본정보를

DB에 저장하다보니

애뮬레이터에서는 잘 돌던 프로그램이

폰으로 옮겼을 때 DB가 없어서

에러가 났다.

그래서 이를 해결하는 방법을 찾다보니

안드로이드에선 주로 assets디렉토리에 파일을 두고

프로그램 실행시 DB로 카피하는 식의 방식을 쓰고 있어

인터넷에서 예제를 구해 나름

작업해보았다.

안드로이드 - 소켓 프로그래밍 (TCP/IP) Server&Client 예제 (쓰레드 활용)

원본출처: http://warmz.tistory.com/597

TcpIpServer.java

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67

import java.io.DataOutputStream; import java.io.IOException; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import java.text.SimpleDateFormat; import java.util.Date;   public class TcpIpServer implements Runnable {     ServerSocket serverSocket;     Thread[] threadArr;       public static void main(String[] args) {         // 5개의 쓰레드를 생성하는 서버를 생성한다.         TcpIpServer server = new TcpIpServer(5);         server.start();     }       public TcpIpServer(int num) {         try {             // 서버 소켓을 생성하여 7777번 포트와 바인딩.             serverSocket = new ServerSocket(7777);             System.out.println(getTime() + " 서버가 준비되었습니다.");               threadArr = new Thread[num];         } catch (IOException e) {             e.printStackTrace();         }     }       public void start() {         for (int i = 0; i < threadArr.length; i++) {             threadArr[i] = new Thread(this);             threadArr[i].start();         }     }       @Override     public void run() {         while (true) {             try {                 System.out.println(getTime() + " 가 연결 요청을 기다립니다.");                   Socket socket = serverSocket.accept();                 System.out.println(getTime() + " " + socket.getInetAddress()                         + "로부터 연결요청이 들어왔습니다.");                   OutputStream out = socket.getOutputStream();                 DataOutputStream dos = new DataOutputStream(out);                   dos.writeUTF("[Notice] Test Message1 from Server");                 System.out.println(getTime() + " 데이터를 전송하였습니다.");                   dos.close();                 socket.close();             } catch (IOException e) {                 e.printStackTrace();             }         }     }       static String getTime() {         String name = Thread.currentThread().getName();         SimpleDateFormat f = new SimpleDateFormat("[hh:mm:ss]");         return f.format(new Date()) + name;     } }

 
TcpIpClient.java

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30

import java.io.DataInputStream; import java.io.InputStream; import java.net.Socket;     public class TcpIpClient {     public static void main(String[] args) {         try{             String serverIp = "127.0.0.1";               // 소켓을 생성하여 연결을 요청한다.             System.out.println("서버에 연결중입니다. 서버IP : " + serverIp);             Socket socket = new Socket(serverIp, 7777);                           // 소켓의 입력스트림을 얻는다.             InputStream in = socket.getInputStream();             DataInputStream dis = new DataInputStream(in);                           // 소켓으로부터 받은 데이터를 출력한다.             System.out.println("서버로부터 받은 메세지 : " + dis.readUTF());             System.out.println("연결을 종료합니다.");                           dis.close();             socket.close();             System.out.println("연결이 종료되었습니다.");         }catch (Exception e) {             e.printStackTrace();         }     } }

 
결과) 서버

[08:22:23]main 서버가 준비되었습니다.

[08:22:23]Thread-0 가 연결 요청을 기다립니다.

[08:22:23]Thread-1 가 연결 요청을 기다립니다.

[08:22:23]Thread-2 가 연결 요청을 기다립니다.

[08:22:23]Thread-3 가 연결 요청을 기다립니다.

[08:22:23]Thread-4 가 연결 요청을 기다립니다.

[08:22:27]Thread-0 /127.0.0.1로부터 연결요청이 들어왔습니다.

[08:22:27]Thread-0 데이터를 전송하였습니다.

[08:22:27]Thread-0 가 연결 요청을 기다립니다.

결과) 클라이언트

서버에 연결중입니다. 서버IP : 127.0.0.1

서버로부터 받은 메세지 : [Notice] Test Message1 from Server

연결을 종료합니다.

연결이 종료되었습니다.

안드로이드 - 전화번호부 관리 프로그램

원본 출처: http://warmz.tistory.com/497

* 친구 부탁으로 간단하게 만든 전화번호부 관리 프로그램.

DirectoryEntry.java

 
PhoneDirectory.java

 
PDGUI.java

안드로이드 - Android에서의 TCP/IP 통신

안드로이드 에뮬레이터와 데스크탑 서버간 TCP/IP통신을 하는 간단한 코드이다.
보통 이런 테스트는 loopback을 이용하면 되지 않을까? 라고 착각하는 사람들이 굉장히 많을 것이다. 
그래서 서버의 주소를 getLocalHost()를 통해 가져오게 되면 완전 삽질이다.
왜냐? 안드로이드 에뮬레이터의 localhost는 안드로이드 에뮬레이터의 네트웍이지 데스크탑의 네트웍이 아니기 때문이다. 따라서 아래의 소스코드는 일단 네트웍이 돌아가는 컴퓨터에서만 작동이 가능하다.

- Android Client의 메인부분

package android.SocketTest;
import android.app.Activity;
import android.os.Bundle;

public class SocketTest extends Activity {

	@Override
	public void onCreate(Bundle icicle) {
		super.onCreate(icicle);
		setContentView(R.layout.main);
		Thread cThread = new Thread(new TCPClient());
		cThread.start();
	}
}


- Client의 실제코드
package android.SocketTest;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

import android.TCPDesktopServer.TCPDesktopServer;
import android.util.Log;

public class TCPClient implements Runnable {
    public void run() {
         try {
        	 // 서버의 주소를 로컬호스트라고 127.0.0.1로 하는 삽질은 하지말것 -_-;
        	 InetAddress serverAddr = InetAddress.getByName(TCPDesktopServer.SERVERIP);
 	 
        	 Log.d("TCP", "C: Connecting...");
        	 Socket socket = new Socket(serverAddr, 4444);
        	 
        	 String message = "Hello from Client";
		     try {
		    	 Log.d("TCP", "C: Sending: '" + message + "'");
		    	 PrintWriter out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true);
		    	 
		    	 out.println(message);
		    	 Log.d("TCP", "C: Sent.");
	             Log.d("TCP", "C: Done.");
		    	 
             } catch(Exception e) {
                 Log.e("TCP", "S: Error", e);
		      } finally {
		        socket.close();
		      }
         } catch (Exception e) {
              Log.e("TCP", "C: Error", e);
         }
    }
}

- 데스크탑 서버 코드
package android.TCPDesktopServer;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPDesktopServer implements Runnable{
	public static final int SERVERPORT = 4444;
	public static final String SERVERIP = "192.168.0.16";
	
	public void run() {
		try {
			System.out.println("S: Connecting...");
			ServerSocket serverSocket = new ServerSocket(SERVERPORT);

			while (true) {
				Socket client = serverSocket.accept();
				System.out.println("S: Receiving...");

				try {
					BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
					String str = in.readLine();
					System.out.println("S: Received: '" + str + "'");
				} catch(Exception e) {
					System.out.println("S: Error");
					e.printStackTrace();
				} finally {
					client.close();
					System.out.println("S: Done.");
				}
			}

		} catch (Exception e) {
			System.out.println("S: Error");
			e.printStackTrace();
		}
	}

	public static void main (String a[]) {
		Thread desktopServerThread = new Thread(new TCPDesktopServer());
		desktopServerThread.start();
	}
}
[출처] Android에서의 TCP/IP 통신|작성자 다빈

원본소스:http://www.devpia.com/Maeul/Contents/Detail.aspx?BoardID=7458&MAEULNO=911&no=54224&page=1

클라이언트 - 서버 - DB로 처리하는 방식입니다.

클라이언트

package com.net1;

import android.app.Activity;

import android.os.Bundle;

import android.view.*;

import android.widget.*;

public class MainApp extends Activity {

ListView lstView;

@Override

    public void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.main);

        lstView = (ListView)findViewById(R.id.lstView);

    }

    public void chulbal(View v){

       //Toast.makeText(this, "시작", 2000).show();

       Connect connect = new Connect();

       connect.connect_server();

      if(v.getId() == R.id.btnCall){ //단순 서버 호출

             connect.send("good");      //호출

             String message = connect.read();   //반환값 얻기

             Toast.makeText(this, message, Toast.LENGTH_SHORT).show();

      }else if(v.getId() == R.id.btnSelect){ //DB 자료 요청

             String[] items = connect.selectData();

             ListAdapter adapter = new ArrayAdapter<String>(this,

                        android.R.layout.simple_list_item_1, items);

             lstView.setAdapter(adapter);

       }

       connect.connect_close();

    }

}

Connect.java -----------

package com.net1;

import java.io.*;

import java.net.*;

import java.util.*;

import android.util.*;

public class Connect {

      private Socket socket;

      private BufferedReader in;

      private PrintWriter out;

      public void connect_server() {

            try {

                  socket = new Socket("xxx.xxx.xxx.xxx", 8888);

                  in = new BufferedReader(new InputStreamReader(socket

                             .getInputStream(), "UTF-8"));

                  out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(), "UTF-8")), true);

            } catch (Exception e) {

                  Log.i("disp", "connect_server err : " + e);

            }

      }

      public void send(String message) { // 메세지 전송(서버 호출)

            try {

                  out.println(message);

                  out.flush();

            } catch (Exception e) {

                  Log.i("disp", "send err : " + e);

            }

      }

      public String read() { // 메세지 수신(서버로부터)

            try {

                  String message = in.readLine();

                  return message;

            } catch (Exception e) {

                  Log.i("disp", "read err : " + e);

                  return "read err:" + e.getMessage();

            }

      }

      public void connect_close() {

            try {

                  in.close();

                  out.close();

                  socket.close();

            } catch (Exception e) {

            }

      }

      public String[] selectData() { // DB의 자료 반환

            String[] items = null;

            try {

                  out.println("selectData"); // 서버에 DB 자료 요청

                  String result = in.readLine();

                  if (!result.equals("select_err")) {

                      StringTokenizer st = new StringTokenizer(result, "$");

                      Log.i("disp", "ssssss : " + st.countTokens());

                      items = new String[st.countTokens()];

                      for (int i = 0; i < items.length; i++) {

                          items[i] = st.nextToken();

                      }

                  }

            } catch (Exception e) {

                  Log.i("disp", "selectData err : " + e);

            }

            return items;

      }

}

selectData 는 서버에서 명령문으로 받아 특정 테이블에 데이터를 넘겨받는 방식으로

구성되어 있습니다.

sql문장 전체를 넘겨 서버에서 리턴값만 받는 방식으로 하셔도 됩니다.

테스트라 간단하게 구성하였습니다.

아래는 서버의 일부 반환 소스입니다.

      public void process(){  //db 자료 처리 후 클라이언트로 전달

            ArrayList<String> list = new ArrayList<String>();

            DbConnect dbConnect = new DbConnect();

            list = dbConnect.selectData();

            if(list.isEmpty()){

                  send("select_err");

            }else{

                  String data = "";

                  for(String s : list){

                        data += s + "$";                   }

                  send(data);

            }

      }

      public ArrayList<String> selectData(){

            ArrayList<String> list = new ArrayList<String>();

            String sql = "select a, b, c from test";

            try {

                  pstmt = conn.prepareStatement(sql);

                  rs = pstmt.executeQuery();

                  while(rs.next()){

                        String data = rs.getString(1) + " " +

                             rs.getString(2) + " " + rs.getString(3);

                        list.add(data);

                  }

            } catch (Exception e) {

                  System.out.println("selectData 오류 : " + e);

            } finally{

                  try {

                        if(rs !=null) rs.close();

                        if(pstmt !=null) pstmt.close();

                  } catch (Exception e2) {}

            }

            return list;

      }