基于JavaFx的Socket多线程通讯程序实例（含：Server端和Client端）

package socketServerDemo; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import java.text.SimpleDateFormat; import java.util.Date; import javafx.collections.ObservableList; import javafx.scene.control.TableView; import javafx.scene.control.TextArea; public class SocketServerMainThread implements Runnable { private ServerSocket serverSocket = null; private ObservableList<ClientBean> clientdata = null; private TextArea txtInfo = null; private TextArea txtSendData = null; private boolean threadStop = false; public boolean isThreadStop() { return threadStop; } public void setThreadStop(boolean threadStop) { this.threadStop = threadStop; } public void setServerSocket(ServerSocket serverSocket) { this.serverSocket = serverSocket; } public void setClientdata(ObservableList<ClientBean> clientdata) { this.clientdata = clientdata; } public void setTxtInfo(TextArea txtInfo) { this.txtInfo = txtInfo; } public void setTxtSendData(TextArea txtSendData) { this.txtSendData = txtSendData; } public SocketServerMainThread() { // TODO Auto-generated constructor stub } @Override public void run() { try { // TODO Auto-generated method stub while (true) { // 有阻塞 -- 客户端连接上来 txtInfo.appendText("正在侦听端口是否有连接请求。\n"); Socket client; client = serverSocket.accept(); txtInfo.appendText(client.getRemoteSocketAddress().toString() + " ： 连接成功 \n"); ClientBean cb = new ClientBean(); cb.setSocket(client); cb.setSeq(clientdata.size()); cb.setIpaddr(client.getInetAddress().getHostAddress()); cb.setConntime((new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(new Date())); cb.setMemo("连接成功!"); clientdata.add(cb); // 创建一个单独的线程处理与客户端的交互 SocketServerForClient ssfc = new SocketServerForClient(client, clientdata, txtInfo, txtSendData); new Thread(ssfc).start(); if (threadStop) { ssfc.setThreadStop(true); break; } } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }