有界面的TCP Socket通信程序
一个非常简单的有界面的TCP Socket的通信程序程序由四个类组成：一个是服务器端；一个是客户端；另外两个是类，用来发送消息和接收消息的。
服务器端TcpServer.java
package TcpChat;import java.awt.*;import java.awt.event.*;import javax.swing.*;import java.io.*;import java.net.*;public class TcpServer { public static void main(String args[]){ //初始化界面 JFrame jf = new JFrame("服务器端"); JTextField field = new JTextField(30); JTextArea area = new JTextArea(); Cursor cursor = new Cursor(Cursor.TEXT_CURSOR); field.requestFocusInWindow(); area.setEditable(false); area.setFont(new Font("宋体",0,14)); JButton clear = new JButton("清屏"); JButton button = new JButton("发送"); Panel panel = new Panel(); panel.add(field); panel.add(button); panel.add(clear); jf.add(area,"Center"); jf.add(panel,"South"); Toolkit toolkit = jf.getToolkit(); Dimension d = toolkit.getScreenSize(); jf.setBounds(d.width/2-268,d.height/2-163,536,327); jf.setResizable(false); jf.setVisible(true); jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); jf.validate(); try{ //在端口2008监听 ServerSocket ss = new ServerSocket(2008); Socket s = ss.accept(); InputStream is = s.getInputStream(); OutputStream os = s.getOutputStream(); DataInputStream dis = new DataInputStream(is); final DataOutputStream dos = new DataOutputStream(os); SendMsg say = new SendMsg(dos,field,button,area,clear); ReceiveMsg receiver = new ReceiveMsg(dis,area); button.addActionListener(say); clear.addActionListener(say); field.addKeyListener(say); jf.addFocusListener(say); receiver.start(); }catch(IOException e){ e.printStackTrace(); } }}
客户端TcpClient.java
package TcpChat;import java.awt.*;import javax.swing.*;import java.io.*;import java.net.*;public class TcpClient { public static void main(String args[]){ //初始化界面 JFrame jf = new JFrame("客户端"); JTextField field = new JTextField(30); field.requestFocusInWindow(); JTextArea area = new JTextArea(); area.setEditable(false); area.setFont(new Font("宋体",0,14)); JButton button = new JButton("发送"); JButton clear = new JButton("清屏"); Panel panel = new Panel(); panel.add(field); panel.add(button); panel.add(clear); jf.add(area,"Center"); jf.add(panel,"South"); Toolkit toolkit = jf.getToolkit(); Dimension d = toolkit.getScreenSize(); jf.setBounds(d.width/2-268,d.height/2-163,536,327); jf.setResizable(false); jf.setVisible(true); jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); jf.validate(); try{ //获取服务器IP和端口号 Socket s = new Socket("127.0.0.1",2008); InputStream is = s.getInputStream(); OutputStream os = s.getOutputStream(); DataInputStream dis = new DataInputStream(is); final DataOutputStream dos = new DataOutputStream(os); SendMsg say = new SendMsg(dos,field,button,area,clear); ReceiveMsg receiver = new ReceiveMsg(dis,area); button.addActionListener(say); clear.addActionListener(say); field.addKeyListener(say); jf.addFocusListener(say); receiver.start(); }catch(IOException e){ e.printStackTrace(); } }}
以上两个基本相似，其差别就在于一个是监听（服务器端），一个是主动连接（客户端），见红色代码。
下面两个是公共类：
发送消息SendMsg.java
package TcpChat;import java.awt.Cursor;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import java.awt.event.FocusEvent;import java.awt.event.FocusListener;import java.awt.event.KeyAdapter;import java.awt.event.KeyEvent;import javax.swing.JButton;import javax.swing.JTextArea;import javax.swing.JTextField;import java.io.DataOutputStream;import java.io.IOException;/** * 发送 * */public class SendMsg extends KeyAdapter implements ActionListener,FocusListener{ private JTextField field; private JTextArea area; private DataOutputStream dos; private JButton button; private JButton clear; public SendMsg(DataOutputStream d,JTextField f,JButton b,JTextArea a,JButton c){ this.dos = d; this.field = f; this.button = b; this.area = a; this.clear = c; } @Override public void keyTyped(KeyEvent e) { if(e.getKeyChar()==(char)KeyEvent.VK_ENTER){ String s = field.getText(); try{ area.append("你说："+s+"\n"); dos.writeUTF(s+"\n"); if(s.equals("bye")){ dos.close(); area.setText("自己下线，程序退出！"); System.exit(0); } field.setText(""); }catch(IOException ee){ ee.printStackTrace(); } } } public void actionPerformed(ActionEvent e){ if(e.getActionCommand().equals("发送")){ String s = field.getText(); try{ area.append("你说："+s+"\n"); dos.writeUTF(s+"\n"); if(s.equals("bye")){ dos.close(); area.setText("自己下线，程序退出！"); System.exit(0); } field.setText(""); }catch(IOException ee){ ee.printStackTrace(); } } if(e.getActionCommand().equals("清屏")){ area.setText(""); } } public void focusGained(FocusEvent e) { Cursor cursor = new Cursor(Cursor.TEXT_CURSOR); field.requestFocusInWindow(); } public void focusLost(FocusEvent e) {} }
接收消息ReceiveMsg.java
package TcpChat;import java.io.DataInputStream;import java.io.IOException;import javax.swing.JTextArea;/** * 接收 * */public class ReceiveMsg extends Thread{ private DataInputStream dis; private JTextArea area; public ReceiveMsg(DataInputStream d,JTextArea a){ this.dis = d; this.area = a; } public void run(){ String s; while(true){ try{ s = dis.readUTF(); area.append("对方说："+s); if(s.equals("bye")){ dis.close(); area.setText("对方下线，程序退出!"); break; } }catch(IOException e){ e.printStackTrace(); } } }}
该程序只具有简单的聊天功能，主要是为了分析socket 通信中服务器和客户端的差异，未考虑关闭程序时关闭端口等因素。附上Eclipse3.4下高度的项目~下载后，直接导入即可运行~
http://dl.iteye.com/upload/attachment/236471/7044a248-18ed-3c14-a5dc-1bb435d17228.jpg
http://dl.iteye.com/upload/attachment/236473/ecb05298-4311-3755-af9b-46b742b92cbe.jpg
页:
[1]