//Server端：
public class 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
