communication-software-server_java_tcp_源码

package com.lee.socket; import com.lee.jdbc.Record; import com.lee.jdbc.RecordDao; import java.awt.EventQueue; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.border.EmptyBorder; import javax.swing.GroupLayout; import javax.swing.GroupLayout.Alignment; import javax.swing.JLabel; import java.awt.Font; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.*; import java.text.SimpleDateFormat; import java.util.Date; import javax.swing.JTextField; import javax.swing.LayoutStyle.ComponentPlacement; import javax.swing.JButton; import javax.swing.JScrollPane; import javax.swing.JTextArea; public class TalkServer extends JFrame { private JPanel contentPane; private JTextField ipText; private JTextField portText; final JButton startBut; final JTextArea textArea; private JTextField msgText; BufferedWriter bw = null; /** * Create the frame. */ public TalkServer() { setTitle("聊天服务器"); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 650, 441); contentPane = new JPanel(); contentPane.setBorder(new EmptyBorder(5, 5, 5, 5)); setContentPane(contentPane); JLabel lblip = new JLabel("本机IP"); lblip.setFont(new Font("宋体", Font.PLAIN, 14)); ipText = new JTextField(); ipText.setColumns(10); ipText.setText("127.0.0.1"); JLabel label = new JLabel("监听端口"); label.setFont(new Font("宋体", Font.PLAIN, 14)); portText = new JTextField(); portText.setColumns(10); portText.setText("9999"); startBut= new JButton("开启服务器"); JLabel label_2 = new JLabel("输入消息"); msgText = new JTextField(); msgText.setColumns(10); JButton send = new JButton("发送"); JScrollPane scrollPane = new JScrollPane(); GroupLayout gl_contentPane = new GroupLayout(contentPane); //自动空隙 //gl_contentPane.setAutoCreateGaps(true); //gl_contentPane.setAutoCreateContainerGaps(true); gl_contentPane.setHorizontalGroup( gl_contentPane.createParallelGroup(Alignment.LEADING) .addGroup(gl_contentPane.createSequentialGroup() .addContainerGap() .addGroup(gl_contentPane.createParallelGroup(Alignment.LEADING) .addGroup(gl_contentPane.createSequentialGroup() .addComponent(lblip, GroupLayout.PREFERRED_SIZE, 55, GroupLayout.PREFERRED_SIZE) .addPreferredGap(ComponentPlacement.RELATED) .addComponent(ipText, GroupLayout.PREFERRED_SIZE, 138, GroupLayout.PREFERRED_SIZE) .addGap(18) .addComponent(label, GroupLayout.PREFERRED_SIZE, 71, GroupLayout.PREFERRED_SIZE) //.addPreferredGap(ComponentPlacement.RELATED) .addComponent(portText, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.PREFERRED_SIZE) .addGap(46) .addComponent(startBut) .addContainerGap(23, Short.MAX_VALUE)) //新增 .addGroup(gl_contentPane.createSequentialGroup() .addComponent(label_2,GroupLayout.PREFERRED_SIZE, 55, GroupLayout.PREFERRED_SIZE) .addGap(20) .addComponent(msgText, GroupLayout.PREFERRED_SIZE, 279, GroupLayout.PREFERRED_SIZE) .addGap(20) .addComponent(send, GroupLayout.PREFERRED_SIZE, 71, GroupLayout.PREFERRED_SIZE) .addGap(20)) .addGroup(gl_contentPane.createSequentialGroup() .addComponent(scrollPane) .addGap(23)))) ); gl_contentPane.setVerticalGroup( gl_contentPane.createParallelGroup(Alignment.LEADING) .addGroup(gl_contentPane.createSequentialGroup() .addGap(28) .addGroup(gl_contentPane.createParallelGroup(Alignment.BASELINE) .addComponent(lblip, GroupLayout.PREFERRED_SIZE, 27, GroupLayout.PREFERRED_SIZE) .addComponent(ipText, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.PREFERRED_SIZE) .addComponent(label, GroupLayout.PREFERRED_SIZE, 27, GroupLayout.PREFERRED_SIZE) .addComponent(portText, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.PREFERRED_SIZE) .addComponent(startBut)) .addGap(18) //新增发送消息框 .addGroup(gl_contentPane.createParallelGroup(Alignment.BASELINE) .addComponent(label_2, GroupLayout.PREFERRED_SIZE, 27, GroupLayout.PREFERRED_SIZE) .addComponent(msgText, GroupLayout.PREFERRED_SIZE, GroupLayout.DEFAULT_SIZE, GroupLayout.PREFERRED_SIZE) .addComponent(send)) .addGap(22) .addComponent(scrollPane, GroupLayout.DEFAULT_SIZE, 307, Short.MAX_VALUE) .addContainerGap()) ); textArea = new JTextArea(); textArea.setFont(new Font("Monospaced", Font.PLAIN, 20)); scrollPane.setViewportView(textArea); contentPane.setLayout(gl_contentPane); startBut.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { ServerOpen serverOpen = new ServerOpen(Integer.parseInt(portText.getText()),textArea); new Thread(serverOpen).start(); while(true) { if(serverOpen.getSocket() != null) { try{ bw = new BufferedWriter(new OutputStreamWriter(serverOpen.getSocket().getOutputStream())); }catch (IOException ex) { System.out.println("没能得到BufferedWriter"); } break; } } } }); send.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { String msg = msgText.getText(); if(msg != "") { try{ send(msg); msgText.setText(""); msgText.requestFocus(); textArea.append("servei " + new Date() + "\n" + msg+ "\n"); }catch (IOException ex) { System.out.println("服务器端发送消息失败"); textArea.append("客户端发送信息错误\n"); } } } }); } //发送信息 void send(String msg) throws IOException{ bw.write(msg); bw.newLine(); bw.flush(); //server发送的信息 SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String dateStr = format.format(new Date()); Record record = new Record(1, dateStr, msg, 2); RecordDao.insertSendRecord(record); } /** * Launch the application. */ public static void main(String[] args) { EventQueue.invokeLater(new Runnable() { public void run() { try { TalkServer frame = new TalkServer(); frame.setVisible(true); } catch (Exception e) { e.printStackTrace(); } } })