聊天.txt

基于java socket的网络聊天程序

>>当前位置：Java大本营>Socket编程>文章内容  
java网络聊天程序的实现 
 
作者： 发布时间：2007-12-04 00:02:06  
 
设计思路
Socket是实现client/server模式的通信方式，它首先要建立稳定的连接，然后以流的方式传输数据，实现网络通信。使用Socket进行Client/Server程序设计的一般连接过程是这样的：Server端监听某个端口是否有连接请求，Client端向Server端发出连接请求，Server端向Client端发回接受消息。一个连接就建立起来了。Server端和Client端都可以通过Send，Write等方法与对方通信。
因为在创建socket时如果发生错误，将会产生IOException，所以在创建ServerSocket和Socket时我用了try-catch-finally语句捕获和处理异常，并通过JOptionPane给用户发出提示。
本程序接收消息的模块使用了教材上的由Socket对象得到输入流，并构造相应的BufferedReader对象的方法，而发送模块是通过构造PrintWriter对象并将数据输出到Server的方法，因为对输出来说，使用Writer方式具有明显的优势。这一优势是通过PrintWriter表现出来的，它有一个过载的构建器，能获取第二个参数：一个布尔值标志，指向是否在每一次println()结束的时候自动刷新输出。每次写入了输出内容后，它的缓冲区必须刷新，使信息能正式通过网络传递出去。这样就能保证信息每次能够及时准确地从发送端发出。
在设计本程序时我还特意将发送消息的日期和时间跟消息一起发送到接收端，这样可以方便用户阅读聊天记录。
设计GUI界面时我用了最常见的模型，即上面有个JTextArea存放聊天记录，下面的JTextArea让用户输入信息，最下方还有三个按钮，用于发送信息，清空记录和关闭窗口。
本程序加入了GUI界面有以下三个原因：
1.由于本程序要实现全双工的网络通信，如果要在DOS界面下实现这种通信方式只有用到多线程，这样就增加了程序 的复杂程度，也更容易出错。而用GUI界面只要对原有程序稍加改动就可以通过JButton事件处理程序实现实时收发 功能而不受顺序的限制。而用同样的核心代码不加GUI界面只能实现半双工的通信模式。
2.在DOS界面下通信只能发英文而不能发中文，而用GUI界面就可以实现中文的收发。
3.GUI界面在人机交互方面更加友好，更加方便，使用起来更顺手。

以下是程序的主要设计思路：
1．先在Server端创建一个ServerSocket监听本机的6789端口，等待客户端的连接请求。
2．Client端启动后，会向客户端的6789端口发出连接请求，当Server端收到请求后会由ServerSocket通过accept()方法返回一个对应的Server端Socket与Client端进行连接，连接后两台机器间就建立了一个Socket——Socket的连接，继而实现Socket之间的通信。此时Server端和Client端就基本没有什么差别了，发送和接收信息都是一样的。
3．创建一个无限循环，由Socket分别得到输入输出流，构造BufferedReader对象存放得到的输入流，并读出输入流中的数据，显示在聊天记录对话框中。用输出流构造一个PrintWriter对象。此时程序的接收功能就有了。
4．用事件处理程序控制信息的发送，当发送按钮按下时，从聊天对话框中取出输入的字符串，并向接收端发送该字符串，刷新输出流，使接收端马上收到该字符串。
5．当按下清除记录按钮时清空所有对话框中的字符。
6．按下关闭按钮时，关闭所有连接并退出程序。此时另一端没有关闭的程序会弹出一个对话框告诉用户连接已经断开。

设计模型
Server端： Client端：



主要程序描述
Server端：
public TCPServer()
{
//调用方法createUserInterface()
createUserInterface();
//用try和catch实现异常的捕获和抛出
try
{
//在与客户端的连接没有建立之前将GUI组件设为不可用
chatJTextArea.setEditable( false );
sendJButton.setEnabled( false );
clearJButton.setEnabled( false );
//在端口6789建立监听socket，并在historyJTextArea中显示提示语
ServerSocket welcomeSocket=new ServerSocket( 6789 );
historyJTextArea.append( "等待连接..."+"\n" );
//当监听socket监听到有客户端连接后建立一个新的socket用于传送数据
//并在historyJTextArea中显示提示语
Socket connectionSocket=welcomeSocket.accept( );
historyJTextArea.append( "连接已建立,端口："+connectionSocket.getLocalPort()+"\n" );
historyJTextArea.append( "主机信息："+connectionSocket.getInetAddress().getLocalHost()+"\n" );
historyJTextArea.append( "socket信息："+connectionSocket+"\n" );
//恢复GUI组件的可用性
chatJTextArea.setEditable( true );
sendJButton.setEnabled( true );
clearJButton.setEnabled( true );
//建立变量fromClient用于存放从客户端接受到的数据
String fromClient;
//通过一个while循环实现连续的接收功能
while( true )
{
//从connectionSocket中取得输出流，并构造PrintWriter对象
OutputStream output=connectionSocket.getOutputStream();
outToClient=new PrintWriter(output,true);
//建立BufferedReader存放从socket中取得的输入流
BufferedReader inFromClient=new BufferedReader(
new InputStreamReader(
connectionSocket.getInputStream( ) ) );
//从输入流缓存区中读取数据存入变量fromClient中
fromClient=inFromClient.readLine( );
if( fromClient!=null)
//在historyJTextArea中显示接收到的数据
{
historyJTextArea.append("Client:"+"\n"+fromClient+"\n");
}
}//end while
}//end try
catch( IOException e )
{
//发生异常时出现提示
JOptionPane.showMessageDialog( null,
e,"发生异常！",
JOptionPane.ERROR_MESSAGE );
}//end catch
finally
{
}//end finally
}
//建立方法sendJButtonActionPerformed用于响应sendJButton的动作
private void sendJButtonActionPerformed( ActionEvent event )
{
//建立变量words存放用户在chatJTextArea里输入的数据
String words=chatJTextArea.getText();
//执行判断，如果用户没有输入数据则提示用户输入数据，如果输入了数据就将其发送到socket中
if( words.equals( "" ) )
{
JOptionPane.showMessageDialog( null,
"输入不能为空,请输入有效字符","输入有误",
JOptionPane.INFORMATION_MESSAGE );
}
else
{
//利用DateFormat的方法getDateTimeInstance取得一个DateFormat对象
//将其存放到time中
DateFormat time=DateFormat.getDateTimeInstance();
//利用new Date()返回当前系统时间，并用time的format方法将其转化为String
//用变量str存放格式化后的要发送的数据
String str=" "+words+"\t"+"("+time.format( new Date() )+")";
try
{
//将str字符串内容发送Client端
outToClient.println(str);
outToClient.flush();
}
catch(Exception e)
{
JOptionPane.showMessageDialog( null,
e,"发生异常！",
JOptionPane.ERROR_MESSAGE );
}
finally
{
}//end finally
sendJButton.requestFocusInWindow();
historyJTextArea.append( "Server:"+"\n"+str+"\n" );
chatJTextArea.setText( "" );
}
}//end method sendJButtonActionPerformed
Client端：
public TCPClient()
{
//调用方法createUserInterface
createUserInterface();
try
{
chatJTextArea.setEnabled( false );
sendJButton.setEnabled( false );
clearJButton.setEnabled( false );
//与主机建立连接并在historyJTextArea中显示提示语
Socket clientSocket=new Socket( "localhost",6789 );
historyJTextArea.append( "连接已建立，端口："+clientSocket.getLocalPort()+"\n" );
historyJTextArea.append( "客户端信息:"+clientSocket.getInetAddress().getLocalHost()+"\n" );
historyJTextArea.append( "socket信息："+clientSocket+"\n" );
chatJTextArea.setEnabled( true );
sendJButton.setEnabled( true );
clearJButton.setEnabled( true );
//建立变量存放从Server端发送过来的数据
String fromServer;
while( true )
{
//从clientSocket中取得输出流，并构造PrintWriter对象
OutputStream output=clientSocket.getOutputStream();
outToServer=new PrintWriter(output,true);
//建立BufferedReader存放从socket中取得的输入流
BufferedReader inFromServer=new BufferedReader(
new InputStreamReader(
clientSocket.getInputStream( ) ) );

//从输入流中缓存区读取数据存入变量fromServer中
fromServer=inFromServer.readLine( );
if( fromServer!=null )
{
//在historyJTextArea中显示接收到的数据
historyJTextArea.append("Server:"+"\n"+fromServer+"\n");
}
}//end while
}//end try
catch( IOException e )
{
//发生异常时出现提示
JOptionPane.showMessageDialog( null,
e,"发生异常！",
JOptionPane.ERROR_MESSAGE );
}//end catch
finally
{
}//end finally
}
//建立方法sendJButtonActionPerformed用于响应sendJButton的动作
private void sendJButtonActionPerformed( ActionEvent event )
{
//建立变量words存放用户在chatJTextArea里输入的数据
String words=chatJTextArea.getText();
//执行判断，如果用户没有输入数据则提示用户输入数据，如果输入了数据就将其发送到socket中
if( words.equals( "" ) )
{
JOptionPane.showMessageDialog( null,
"输入不能为空,请输入有效字符","输入有误",
JOptionPane.INFORMATION_MESSAGE );
}
else
{
//利用DateFormat的方法getDateTimeInstance取得一个DateFormat对象
//将其存放到time中
DateFormat time=DateFormat.getDateTimeInstance();
//利用new Date()返回当前系统时间，并用time的format方法将其转化为String
//用变量str存放格式化后的要发送的数据
String str=" "+words+"\t"+"("+time.format( new Date() )+")";
try
{
//将str字符串内容发送到Server端
outToServer.println(str);
outToServer.flush();
}
catch(Exception e)
{
JOptionPane.showMessageDialog( null,
e,"发生异常！",
JOptionPane.ERROR_MESSAGE );
}
finally
{
}//end finally
sendJButton.requestFocusInWindow();
historyJTextArea.append( "Client:"+"\n"+str+"\n" );
chatJTextArea.setText( "" );
}
}//end method sendJButtonActionPerformed