lanchatv12.java

java聊天室的c/s模式

//用 Java 编写的聊天器，可以当 服务器 或者 是客户端，一对一，自定义对方 IP 及 端口。 
//虽然名为 LANChat ，但不限于局域网。对象甚至可以是某种 “服务器”。 

//lili,23:28,2007\02\11 complete,all rights reserved. 
//QQ:151241801,E-mail:[e-mail]. 

/////////////////////////////////////////////////////////// 

//lili,12:38,2007\02\12,合并了代码，程序减少 40 多行 
//lili,22:17,2007\02\14,解决了输入框的焦点问题 

/////////////////////////////////////////////////////////// 

import java.io.*; 
import java.net.*; 
import java.awt.*; 
import javax.swing.*; 
import java.awt.event.*; 

////////////////////////////////////////////////////////// 

public class LANChatV12{ 
public static void main(String args[]){ 
LoginFrame lf = new LoginFrame("输入目标"); 
lf.show(); 
} 
} 

///////////////////////////////////////////////////////// 

class LoginFrame extends JFrame{ 
JButton BOK; 
JLabel LdesAddr, Lport; 
JTextField TFdesAddr, TFport; 
String desAddr, port; 

LoginFrame(){} 

LoginFrame(String title){ 
super(title); 
Frame t = this; 
BOK = new JButton("确定"); 
LdesAddr = new JLabel("目标 IP"); 
Lport = new JLabel("端口 "); 
TFdesAddr = new JTextField(desAddr,12); 
TFport = new JTextField(port,12); 
//TFpassword.setEchoChar('*'); 
BOK.addActionListener(new BOKListener(t)); 
setBackground(Color.blue); 
setBounds(350,250,200,128); 
setLayout(new FlowLayout(FlowLayout.CENTER,5,7)); 
add(LdesAddr); 
add(TFdesAddr); 
add(Lport); 
add(TFport); 
add(BOK); 
setResizable(false); 
//setVisible(true); 
addWindowListener(new WindowAdapter(){ 
public void windowClosing(WindowEvent e){ 
System.exit(0); 
} 
}); 
} 

class BOKListener implements ActionListener{ 
Frame t; 

BOKListener(){} 

BOKListener(Frame t){ 
this.t = t; 
} 

public void actionPerformed(ActionEvent e){ 
desAddr = TFdesAddr.getText(); 
port = TFport.getText(); 
t.setVisible(false); 
Messenger m = new Messenger(desAddr, port); 
m.start(); 
} 
} 
} 

///////////////////////////////////////////////////// 

class Messenger extends Thread{ 
String desAddr; 
String port; 
int iport; 
TextArea content, send; 
JButton Bsend;
JButton Bsend2; 
ChatFrame cf; 
String title; 
Socket client; 
ServerSocket ss; 
OutputStreamWriter osw = null; 
InputStreamReader isr = null; 
BufferedReader br; 
String line; 
boolean flag;//端口号是否正确 
boolean cbc; //can be client ? 
int tryTurns = 3; //客户方式尝试的次数 

Messenger(){} 

Messenger(String desAddr, String port){ 
super("LANChatMessenger"); 
content = new TextArea("",0,0,TextArea.SCROLLBARS_VERTICAL_ONLY); 
send = new TextArea("",0,0,TextArea.SCROLLBARS_VERTICAL_ONLY); 
Bsend = new JButton("发送"); 
Bsend2 = new JButton("asasas"); 
Bsend.setEnabled(false);
Bsend2.setEnabled(false);
title = "与 " + desAddr +" 聊天"; 
flag = true; 
cbc = true; 

cf = new ChatFrame(title, content, send, Bsend); 
cf.show(); 

this.desAddr = desAddr; 
this.port = port; 
try{ 
iport = Integer.parseInt(port); 
}catch(NumberFormatException nfe){ 
content.append("非法的 端口，程序 4 秒后关闭。\n"); 
flag = false; 
} 
} 

public void run(){ 
if(! flag){ 
try{ 
Thread.sleep(4000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
System.exit(0); 
} 

content.append("正在以客户端方式进行连接.....\n"); 
do{ 
cbc = true; 
try{ 
client = new Socket(desAddr,iport); 
}catch(Exception e){ 
content.append("错误，无法连接地址：" + desAddr +":"+ port + '\n'); 
content.append("等待 1 秒再连接，剩余 [ " + (tryTurns -1) + " ]次。\n"); 
cbc = false; 
try{ 
Thread.sleep(1000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
} 
--tryTurns; 
}while((tryTurns > 0) && ! cbc); 

if(cbc){ 
content.append("连接成功，可以开始了。" + "\n\n"); 
cf.setTitle("与 " + desAddr + ":" + port + " 聊天"); 
send.requestFocus(); 
} 

else{ 
content.append("客户端方式失败，现在启动服务器并等待连接。" + '\n'); 
try{ 
ss = new ServerSocket(iport); 
}catch(IOException ioe){ 
content.append("\n无法创建服务，程序将在 4 秒后退出。\n"); 
try{ 
Thread.sleep(4000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
System.exit(0); 
} 
try{ 
cf.setTitle("等待连接中....在端口：" + port); 
client = ss.accept(); 
}catch(Exception e){ 
content.append("\nss.accept() 方法失败，程序将在 4 秒后退出。\n"); 
try{ 
Thread.sleep(4000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
System.exit(0); 
} 
content.append("连接成功，可以开始。" + client.getInetAddress().toString() + "\n\n"); 
cf.setTitle("与 " + client.getInetAddress().toString() + ":" + port + " 聊天"); 
send.requestFocus(); 
} 
try{ 
osw = new OutputStreamWriter(client.getOutputStream()); 
isr = new InputStreamReader(client.getInputStream()); 
br= new BufferedReader(isr); 
//content.append("\nbr created\n"); 
}catch(IOException ioe){ 
content.append("创建流错误，程序将在 4 秒后退出。\n"); 
try{ 
Thread.sleep(4000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
System.exit(0); 
} 
Bsend.setEnabled(true); 
Bsend.addActionListener(new BsendListener(content, send, osw)); 
try{ 
line = br.readLine(); 
}catch(IOException ioe){ 
content.append("流读取错误，程序将在 4 秒后退出。\n"); 
try{ 
Thread.sleep(4000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
System.exit(0); 
} 
while(true){ 
content.append("他说 : " + line + '\n'); 
try{ 
Thread.sleep(1000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
try{ 
line = br.readLine(); 
}catch(IOException ioe){ 
content.append("流读取错误，程序将在 4 秒后退出。\n"); 
try{ 
Thread.sleep(4000); 
}catch(InterruptedException ie){ 
System.exit(0); 
} 
System.exit(0); 
} 
} 
} 

class BsendListener implements ActionListener{ 
TextArea content; 
TextArea send; 
OutputStreamWriter osw; 

BsendListener(TextArea content, TextArea send, OutputStreamWriter osw){ 
this.content = content; 
this.send = send; 
this.osw = osw; 
} 

public void actionPerformed(ActionEvent e){ 
String input; 
input = send.getText(); 
if(input.length() > 0){ 
content.append("我说 : " + input + '\n'); 
try{ 
osw.write(input + '\n', 0, input.length() + 1); 
osw.flush();// 晕 
}catch(Exception ee){ 
content.append("不能发送 \"" + input + "\" , 发生了错误 : " +ee.getMessage() + '\n'); 
} 
send.setText(""); 
send.requestFocus(); 
} 
} 
} 
} 

/////////////////////////////////////////////////////////////// 

class ChatFrame extends JFrame{ 
TextArea content; 
TextArea send; 
JButton Bsend; 
JButton Bsend2; 

ChatFrame(){} 

ChatFrame(String frameTitle,TextArea content, TextArea send, JButton Bsend,JButton Bsend2){ 
super(frameTitle); 
this.content = content; 
this.send = send; 
this.Bsend = Bsend; 

this.send.setEditable(true); 
setLayout(null); 
setBounds(300,100,510,500); 
add(content); 
content.setBackground(Color.WHITE); 
content.setBounds(2,0,500,340); 
content.setFocusable(true); 
add(send); 
send.setBounds(2,355,500,70); 
send.setFocusable(true); 
add(Bsend); 
Bsend.setBounds(410,432,60,30); 
setResizable(false); 
setDefaultCloseOperation(EXIT_ON_CLOSE); 
} 
} 

/////////////////////////////////////////////////////////////