完成图形界面的单向数据传输。
NET/SocketTest1.java
package cn.antraces.NET;
import javax.swing.;
import java.awt.;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;
public class SocketTest1 implements Runnable{
public JFrame jf;
public JPanel jp;
public JButton jButton_Send, jButton_Stop;
public JTextArea jTextArea;
public JTextField jTextField;
public JScrollPane jScrollPane;
public Socket socket1, socket2;
public ServerSocket serverSocket;
public BufferedReader bufferedReader;
public int m;
public boolean on;
@Override
public void run() {
try {
if (m == 1) {
server();
} else if (m == 2) {
on = true;
socket2 = new Socket("127.0.0.1",23333);
bufferedReader = new BufferedReader(new InputStreamReader(socket2.getInputStream()));
while (on){
client();
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
public SocketTest1(int m){
this.m = m;
String title = "";
if (m == 1) {
title = "服务端";
} else if (m == 2) {
title = "客户端";
}
JFrame jf = new JFrame(title);
jf.setSize(400, 400);
jf.setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);
jf.setLocationRelativeTo(null);
jf.setResizable(false);
JPanel jp = new JPanel(new FlowLayout());
jTextField = new JTextField(16);
jTextField.setFont(new Font(null, Font.PLAIN, 18));
jButton_Send = new JButton("发送");
jButton_Stop = new JButton("断开");
jButton_Send.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent actionEvent) {
PrintWriter printWriter = null;
try {
printWriter = new PrintWriter(socket1.getOutputStream(), true);
} catch (IOException e) {
e.printStackTrace();
}
printWriter.println(jTextField.getText());
String str = "";
Date nowDate = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss:SSS");
if ((str = jTextArea.getText()) != null) {
jTextArea.setText(str + "\r\n" + sdf.format(nowDate.getTime()) + "\r\n " + jTextField.getText());
}
jTextField.setText("");
}
});
jButton_Stop.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent actionEvent) {
try {
if (m == 1) {
jTextField.setEditable(false);
jTextArea.setText(jTextArea.getText() + "\r\n" + "-=-=-=-=-=-=-=-=-=-连接已断开-=-=-=-=-=-=-=-=-=-");
socket1.close();
serverSocket.close();
} else if (m == 2) {
on = false;
jTextArea.setText(jTextArea.getText() + "\r\n" + "-=-=-=-=-=-=-=-=-=-连接已断开-=-=-=-=-=-=-=-=-=-");
socket2.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
});
jTextArea = new JTextArea(19, 32);
jTextArea.setText("-=-=-=-=-=-=-=-=-=-连接已启动-=-=-=-=-=-=-=-=-=-");
jTextArea.setLineWrap(false);
jTextArea.setEnabled(false);
jScrollPane = new JScrollPane(jTextArea);
if (m == 1) {
jp.add(jTextField);
jp.add(jButton_Send);
}
jp.add(jButton_Stop);
jp.add(jScrollPane);
jf.setContentPane(jp);
jf.setVisible(true);
Thread th = new Thread(this);
th.start();
}
public void server() throws IOException {
serverSocket = new ServerSocket(23333);
socket1 = serverSocket.accept();
}
public void client() throws IOException {
String str = bufferedReader.readLine();
if (str != null) {
Date nowDate = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss:SSS");
jTextArea.setText(jTextArea.getText() + "\r\n" + sdf.format(nowDate.getTime()) + "\r\n " + str);
}
}
public static void main (String[] args){
new SocketTest1(1);
new SocketTest1(2);
}
`}
`