當前位置 主頁 > 網站技術 > 代碼類 > 最大化 縮小

    基于java socket實現 聊天小程序

    欄目:代碼類 時間:2019-12-31 15:06

    服務器

    package demo04;
    import java.awt.BorderLayout;
    import java.awt.event.ActionEvent;
    import java.awt.event.ActionListener;
    import java.awt.event.WindowAdapter;
    import java.awt.event.WindowEvent;
    import java.io.DataInputStream;
    import java.io.DataOutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    import javax.swing.JButton;
    import javax.swing.JFrame;
    import javax.swing.JOptionPane;
    import javax.swing.JPanel;
    import javax.swing.JScrollPane;
    import javax.swing.JTextArea;
    import javax.swing.JTextField;
    import javax.swing.ScrollPaneConstants;
    public class ownServer {
     public static void main(String[] args) {
     // TODO Auto-generated method stub
     new Server().launch();
     }
    }
    class Server{
     JFrame frame;
     JTextArea taArea;
     JTextField tfField;
     JButton sbButton;
     DataInputStream read ;
     DataOutputStream write;
     ServerSocket scServerSocket; 
     Socket socket;
     
     public void launch() {
     CreateUI();
     CreateNetWork();
     new ServerWrite().start();
     new ServerRead().start();
     } 
     public void CreateUI() {
     frame = new JFrame("MM Server");
     JPanel Panle = new JPanel();
     taArea = new JTextArea(15,25);
     taArea.setLineWrap(true);
     taArea.setWrapStyleWord(true);
     taArea.setEditable(true);
     JScrollPane qScroller=newJScrollPane(taArea); 
     qScroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);         
     qScroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_ALWAYS);
     tfField = new JTextField(20);
     sbButton = new JButton("發送");
     Panle.add(qScroller);
     Panle.add(tfField);
     Panle.add(sbButton); 
        frame.getContentPane().add(BorderLayout.CENTER,Panle);
        frame.setSize(400,400);
        frame.setVisible(true); 
     }
     public void close()
     {
     try
     {
      write.close();
      read.close();
      socket.close();
      scServerSocket.close();
     }
     catch (Exception e)
     {
      System.exit(-1);
     }
     } 
     public void CreateNetWork() { 
      
     try {
       scServerSocket =new ServerSocket(7780);
      socket= scServerSocket.accept();
      read = new DataInputStream(socket.getInputStream());
      write = new DataOutputStream(socket.getOutputStream());  
      System.out.print("網絡連接");
     
     } catch (Exception e) {
      // TODO: handle exception
      e.printStackTrace();
     } 
     }
     class ServerRead extends Thread{
     public void run() { 
      while (true) {
       try {
       String message = read.readUTF();
       taArea.append("對方:"+message+ "\n");
      } catch (Exception e1) {
      // TODO: handle exception
      JOptionPane.showMessageDialog(taArea, "提示: 服務端已經斷開連接");
      
      //e.printStackTrace();
      //System.exit(-1);
      return ;
      }  
      }
     }
     }
    class ServerWrite extends Thread{
     
     public void run() {
      tfField.addActionListener(new ServerListen());
      sbButton.addActionListener(new ServerListen());
     }
     }
     class ServerListen implements ActionListener{
     @Override
     public void actionPerformed(ActionEvent e) {
      try {
      String str = tfField.getText();
      tfField.setText("");
      taArea.append("我: " + str + "\n");
      write.writeUTF(str);
      
      } catch (Exception e2) {
      // TODO: handle exception
      e2.printStackTrace();
      }
     } 
     } 
    }
    
    下一篇:沒有了
青海十一选五开奖数据