TCP_Socket 통신

-----------------------------------------------------------------

TCP_SERVER

-----------------------------------------------------------------

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class TCPserver implements Runnable {

public static final int ServerPort = 4444;

public static final String ServerIP = "192.168.0.35";

String result;

@Override

public void run() {

// TODO Auto-generated method stub

try {

System.out.println("Server: Connecting...");

ServerSocket serverSocket = new ServerSocket(ServerPort);

while (true) {

// accept 연결 소켓이 만들어지고 그것을 받아들입니다. 메서드 블록 연결이 만들 때까지.

Socket client = serverSocket.accept();

// client = Socket[addr=/192.168.0.35,port=3148,localport=4444]

// System.out.println(client);

System.out.println("result: Receiving...");

try {

BufferedReader in = new BufferedReader(

new InputStreamReader(client.getInputStream()));

String str = in.readLine();

System.out.println("result: Received: '" + str + "'");

insert(str);

// 기본 문자 인코딩을 사용하는 OutputStreamWriter를 생성합니다.

// getOutputStream = 이 소켓에 대한 반환 출력 스트림

// PrintWriter객체를 생성할때 Autoflush 아규먼트를 가지는 생성자가 있더라..

// 아래와 같이 생성하면 out.println() 혹은 out.print() 메소드 호출시 버퍼에서

// 해당 outputstream 혹은 Writer으로 뱉어내준다.

PrintWriter out = new PrintWriter(new BufferedWriter(

new OutputStreamWriter(client.getOutputStream())),

true);

out.println(result);

} catch (Exception e) {

System.out.println("result: Error");

e.printStackTrace();

} finally {

client.close();

System.out.println("result: Done.");

}

}

} catch (Exception e) {

System.out.println("result: Error");

e.printStackTrace();

}

}

public void insert(String inData) {

String id = null;

String pw = null;

String email = null;

String exist = null;

System.out.println("inData : " +inData);

String str = inData;

String[] values = str.split(",");

id = values[0];

pw = values[1];

email = values[2];

System.out.println("id : " +id);

System.out.println("pw : " +pw);

System.out.println("email : " +email);

Connection conn = null;

String DB_URL = "jdbc:mysql://localhost:3306/test_db"; // test는 db명이다.

String DB_USER = "root"; // 말 그대로 user id

String DB_PASSWORD = "apmsetup"; // 말 그대로 user password

String table = "test_db.createtest1";

// Statement stmt;

try {

// The newInstance() call is a work around for some

// broken Java implementations

Class.forName("com.mysql.jdbc.Driver");

} catch (Exception ex) {

// handle the error

}

try {

conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);

// System.out.print("성공");

} catch (SQLException ex) {

// handle any errors

System.out.println("SQLException: " + ex.getMessage());

System.out.println("SQLState: " + ex.getSQLState());

System.out.println("VendorError: " + ex.getErrorCode());

}

Statement stmt = null;

ResultSet rs = null;

try {

stmt = conn.createStatement();

String sql = "insert into "+ table +"(id,pw,email) " +

"values('" + id + "','" + pw +"'" + email + "')";

// or alternatively, if you don't know ahead of time that

// the query will be a SELECT...

stmt.executeUpdate(sql);

stmt.close();

conn.close();

result = "S";

} catch (Exception ex) {

// handle the error

result = "F";

}

}

/**

* @param args

*/

public static void main(String[] args) {

// TODO Auto-generated method stub

Thread desktopServerThread = new Thread(new TCPserver());

desktopServerThread.start();

}

}

--------------------------------------------------------------------------

TCP_Client

--------------------------------------------------------------------------

package android.SocketTest;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.Socket;

import android.SocketTest.R;

import android.SocketTest.R.id;

import android.SocketTest.R.layout;

import android.app.Activity;

import android.os.Bundle;

import android.util.Log;

import android.view.View;

import android.view.View.OnClickListener;

import android.widget.Button;

import android.widget.EditText;

import android.widget.TextView;

import android.widget.Toast;

public class SocketTest extends Activity {

/** Called when the activity is first created. */

private String return_msg;

@Override

public void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.main);

final EditText id = (EditText) findViewById(R.id.EditText01);

final EditText pw = (EditText) findViewById(R.id.EditText02);

final EditText em = (EditText) findViewById(R.id.EditText03);

Button btn = (Button) findViewById(R.id.Button01);

final TextView tv = (TextView) findViewById(R.id.TextView01);

btn.setOnClickListener(new OnClickListener() {

public void onClick(View v) {

if (id.getText().toString() != null

|| !id.getText().toString().equals("")

|| !pw.getText().toString().equals(""))

{

TCPclient tp = new TCPclient(id.getText().toString()+

","+pw.getText().toString()+

","+em.getText().toString());

tp.run();

if(return_msg.equals("S")){

return_msg = "가입완료";

}else if(return_msg.equals("R")){

return_msg = "ID가 존재";

}else{

return_msg = "가입실패";

}

Toast t = Toast.makeText(getApplicationContext(),

return_msg, Toast.LENGTH_LONG);

t.show();

tv.setText(return_msg);

}

}

});

}

private class TCPclient implements Runnable {

private static final String serverIP = "192.168.0.35";

private static final int serverPort = 4444;

private String msg;

// private String return_msg;

public TCPclient(String _msg) {

this.msg = _msg;

}

@Override

public void run() {

// TODO Auto-generated method stub

try {

InetAddress serverAddr = InetAddress.getByName(serverIP);

Log.d("TCP", "C: Connecting...");

Socket socket = new Socket(serverAddr, serverPort);

try {

Log.d("TCP", "C: Sending: '" + msg + "'");

PrintWriter out = new PrintWriter(new BufferedWriter(

new OutputStreamWriter(socket.getOutputStream())),

true);

out.println(msg);

Log.d("TCP", "C: Sent.");

Log.d("TCP", "C: Done.");

BufferedReader in = new BufferedReader(

new InputStreamReader(socket.getInputStream()));

return_msg = in.readLine();

Log.d("TCP", "C: Server send to me this message -->"

+ return_msg);

} catch (Exception e) {

Log.e("TCP", "C: Error1", e);

} finally {

socket.close();

}

} catch (Exception e) {

Log.e("TCP", "C: Error2", e);

}

}

}

}