package se.ks;

import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Scanner;

import android.app.Activity;
import android.content.Intent;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;

public class talkbody extends Activity implements OnClickListener {
ArrayList<talkdbitem> mItems;
talkCustomDBAdapter mAdapter;
TextView textview;
String line,line1,send;
@Override
protected void onCreate(Bundle savedInstanceState) {
// TODO Auto-generated method stub
super.onCreate(savedInstanceState);
setContentView(R.layout.talkbody);
textview = (TextView)findViewById(R.id.chatlist);
 
   Intent intent = getIntent();
String name = intent.getStringExtra("param1");
String contents = intent.getStringExtra("param2");
try {
Socket socket = new Socket("210.110.169.63", 6001);
new Chat_Send_Thread(socket).start();
new Chat_Receive_Thread(socket).start();
Toast.makeText(this, "접속되엇습니다.", Toast.LENGTH_LONG).show();
}catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void onClick(View v) {
// TODO Auto-generated method stub
Intent intent = null;
EditText etxt = (EditText)findViewById(R.id.chattext);
switch(v.getId()){
case R.id.btn1:
intent = new Intent(this, board.class);
startActivity(intent);
finish();
break;
case R.id.btn2:
intent = new Intent(this, friends.class);
startActivity(intent);
finish();
break;
case R.id.btn4:
intent = new Intent(this, setting.class);
startActivity(intent);
finish();
break;
case R.id.chatcontents:
send= etxt.getText().toString();
Socket socket = null;
PrintWriter so;
try {
so = new PrintWriter(socket.getOutputStream());
so.println(send);
so.flush();
so.close();
socket.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

public class Chat_Receive_Thread extends Thread{
Socket socket;
int size;
String line = "";
byte[] w= new byte[10240];
InputStream in;
public Chat_Receive_Thread(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try {
//Scanner si= new Scanner(socket.getInputStream());
in = socket.getInputStream();
/* line = si.nextLine();
textview.setText(line);
if(line.equals("exit"))break;*/
size = in.read(w);
//if(size<=0) continue;
line = new String(w,0,size,"UTF-8");
textview.setText(line);
} catch (Exception e) {
e.printStackTrace();
}
}
}

public class Chat_Send_Thread extends Thread{
Socket socket;
public Chat_Send_Thread(Socket socket) {
this.socket = socket;
}
}
}


클라이언트에서 쓴글이 한번은 받아와 지는데 두번은 안받아지네요.. 그리고 전송이 안되는데 아시는 분 댓글좀.