ring[] args) {
new ChatClient().launchFrame();
}
public void launchFrame() {
setLocation(400, 300);
this.setSize(300, 300);
add(tfTxt,BorderLayout.SOUTH);
add(taContent,BorderLayout.NORTH);
pack(); //包在一起,去掉中间空着的
this.addWindowListener(new WindowAdapter(){
public void windowClosing(WindowEvent e){
disconnect();
System.exit(0);
}
});
tfTxt.addActionListener(new TfListent());
setVisible(true);
connect();
tRecv.start(); //启动线程
}
public void connect(){
try {
s = new Socket("127.0.0.1",8888);//注意不要定义成Socket s,这就成了局部变量而不是成员变量了
System.out.println("connected!");
dos = new DataOutputStream(s.getOutputStream());
dis = new DataInputStream(s.getInputStream());
cont = true;
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void disconnect(){
try {
dos.close();
dis.close();
s.close();
} catch (IOException e) {
e.printStackTrace();
}
/*//无法解决readUTF阻塞式方法
try {
cont = false; //关闭线程
tRecv.join(); //合并线程,彻底让他停止
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
try {
dos.close(); //线程停止之后才能关流,不然抛SocketException异常
dis.close();
s.close();
} catch (IOException e) {
e.printStackTrace();
}
}
*/
}
private class TfListent implements ActionListener {
public void actionPerformed(ActionEvent e) {
String str = tfTxt.getText().trim();
tfTxt.setText("");
try {
dos.writeUTF(str);
dos.flush();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
private class RecvThread implements Runnable{
public void run() {
try {
while(cont){
String str = dis.readUTF();
taContent.setText(taContent.getText() + str + '\n');
}
} catch (SocketException e){
System.out.println("退出了,bye!");
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
简单的聊天程序,主要用到的是Socket,线程以及流
如果没看懂可以去下载
verycd/topics/93279/
尚学堂科技_马士兵_在线聊天
系统雏形视频教程_java_eclipse.rar
1.客户端
package com.client;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.swing.UIManager;
import javax.swing.UnsupportedLookAndFeelException;
import com.ui.ChatUI;
public class Client extends ChatUI implements ActionListener {
private String content = "";
Socket socket;
DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public static int i;
public Client() {
super("?客户端:");
getSendBtn().addActionListener(this);
getCancelBtn().addActionListener(this);
try {
++i;
socket = new Socket("localhost", 1234);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void actionPe