詳解基於java的Socket聊天順序——客戶端（附demo）。本站提示廣大學習愛好者：（詳解基於java的Socket聊天順序——客戶端（附demo））文章只能為提供參考，不一定能成為您想要的結果。以下是詳解基於java的Socket聊天順序——客戶端（附demo）正文
寫在後面：
上周末抽點時間把自己寫的一個復雜Socket聊天順序的初始設計和服務端細化設計記載了一下，周二終於等來畢業前考的軟考證書，然後接上去就是在加班的日子渡過了，明天正好周五，計劃把客戶端的詳細設計和Common模塊記載一下，由於這個周末開端就要去忙其他東西了。
設計：
客戶端設計次要分紅兩個局部，辨別是socket通訊模塊設計和UI相關設計。
客戶端socket通訊設計：
這裡的設計其實跟服務端的設計差不多，不同的是服務端是接納心跳包，而客戶端是發送心跳包，由於客戶端只與一個服務端停止通訊（客戶端之間的通訊也是由服務端停止分發的），所以這裡只運用了一個大小為2的線程池去處置這兩件事（newFixedThreadPool(2)），對應的處置類辨別是ReceiveListener、KeepAliveDog，其中ReceiveListener在初始化的時分傳入一個Callback作為客戶端收到服務端的音訊的回調，Callback的默許完成是DefaultCallback，DefaultCallback依據不同的事情經過HF分發給不同Handler去處置，而ClientHolder則是存儲以後客戶端信息，設計如下：
Socket通訊模塊詳細完成：
[Client.java]
Client是客戶端銜接服務端的入口，創立Client需求指定一個Callback作為客戶端接納服務端音訊時的回調，然後由Client的start()辦法啟動對服務端的監聽（ReceiveListener），當ReceiveListener接納到服務端發來的數據時，調用回調（Callback）的doWork()辦法去處置；同時Client中還需求發送心跳包來告訴服務端自己還在銜接著服務端，發心跳包由Client中keepAlive()啟動，由KeepAliveDog完成；這兩個步驟由一個固定大小為2為線程池newFixedThreadPool(2)去執行，能夠這裡運用一個newFixedThreadPool(1)和newScheduledThreadPool(1)去處置更合理，由於心跳包是定時發的，服務端就是這樣完成的（這個後續調整），Client的詳細代碼如下（這裡暴露了另外兩個辦法用於獲取socket和以後socket所屬的用戶）：
/**
* 客戶端
* @author yaolin
*
*/
public class Client {
private final Socket socket;
private String from;
private final ExecutorService pool;
private final Callback callback;
public Client(Callback callback) throws IOException {
this.socket = new Socket(ConstantValue.SERVER_IP, ConstantValue.SERVER_PORT);
this.pool = Executors.newFixedThreadPool(2);
this.callback = callback;
}
public void start() {
pool.execute(new ReceiveListener(socket, callback));
}
public void keepAlive(String from) {
this.from = from;
pool.execute(new KeepAliveDog(socket, from));
}
public Socket getSocket() {
return socket;
}
public String getFrom() {
return from;
}
}
[KeepAliveDog.java]
客戶端在與服務端樹立銜接之後（該順序中是指登陸成功之後，由於登陸成功之後客戶端的socket才會被服務端的SocketHolder管理），需求每個一段時間就給服務端發送心跳包通知服務端自己還在跟服務端堅持聯絡，不然服務端會在一段時間之後將沒有交互的socket丟棄（詳見服務端那篇博客），KeepAliveDog的代碼完成如下（前期能夠會調整為newScheduledThreadPool(1)，所以這裡的代碼也會調整）：
/**
* KeepAliveDog : tell Server this client is running;
*
* @author yaolin
*/
public class KeepAliveDog implements Runnable {
private final Socket socket;
private final String from;
public KeepAliveDog(Socket socket, String from) {
this.socket = socket;
this.from = from;
}
@Override
public void run() {
while (socket != null && !socket.isClosed()) {
try {
PrintWriter out = new PrintWriter(socket.getOutputStream());
AliveMessage message = new AliveMessage();
message.setFrom(from);
out.println(JSON.toJSON(message));
out.flush();
Thread.sleep(ConstantValue.KEEP_ALIVE_PERIOD * 1000);
} catch (Exception e) {
LoggerUtil.error("Client send message failed !" + e.getMessage(), e);
}
}
}
}
[ReceiveListener.java]
Client的start()辦法啟動對服務端的監聽由ReceiveListener完成，ReceiveListener接納到服務端的音訊之後會回調Callback的doWork()辦法，讓回調去處置詳細的業務邏輯，所以ReceiveListener只擔任監聽服務端的音訊，詳細的處置由Callback擔任，這裡需求提一下的是當音訊類型是文件類型的時分會睡眠配置執行的距離時間，這樣Callback中的doWork才干對讀取來至服務端的文件流，而不是直接進入下一次循環，這裡的設計跟服務端是相似的。ReceiveListener的詳細完成代碼如下：
public class ReceiveListener implements Runnable {
private final Socket socket;
private final Callback callback;
public ReceiveListener(Socket socket, Callback callback) {
this.socket = socket;
this.callback = callback;
}
@Override
public void run() {
if (socket != null) {
while (!socket.isClosed()) {
try {
InputStream is = socket.getInputStream();
String line = null;
StringBuffer sb = null;
if (is.available() > 0) {
BufferedReader bufr = new BufferedReader(new InputStreamReader(is));
sb = new StringBuffer();
while (is.available() > 0 && (line = bufr.readLine()) != null) {
sb.append(line);
}
LoggerUtil.trach("RECEIVE [" + sb.toString() + "] AT " + new Date());
callback.doWork(socket, sb.toString());
BaseMessage message = JSON.parseObject(sb.toString(), BaseMessage.class);
if (message.getType() == MessageType.FILE) {
// PAUSE TO RECEIVE FILE
LoggerUtil.trach("CLIENT:PAUSE TO RECEIVE FILE");
Thread.sleep(ConstantValue.MESSAGE_PERIOD);
}
} else {
Thread.sleep(ConstantValue.MESSAGE_PERIOD);
}
} catch (Exception e) {
LoggerUtil.error("Client send message failed !" + e.getMessage(), e);
}
}
}
}
}
[Callback.java、DefaultCallback.java]
從下面可以看出Client抵消息的處置是Callback回調，其Callback只是一個接口，一切Callback完成該接口依據自己的需求抵消息停止相應地處置，這裡Callback默許的完成是DefaultCallback，DefaultCallback只對三種音訊停止處置，辨別是聊天音訊、文件音訊、前往音訊。關於聊天音訊，DefaultCallback將經過UI中的Router路由獲取到相應的界面（詳見上面的UI設計），然後將音訊展示在對應的聊天框中；關於文件音訊，DefaultCallback則是將文件寫入到配置中指定的途徑中（這裡沒有經過用戶的允許就接納文件，這種設計不是很敵對，目前先這樣）;關於前往音訊，DefaultCallback會依據前往音訊中的KEY叫給不同的Handler去處置。詳細代碼如下：
public interface Callback {
public void doWork(Socket server, Object data);
}
public class DefaultCallback implements Callback {
@Override
public void doWork(Socket server, Object data) {
if (data != null) {
BaseMessage message = JSON.parseObject(data.toString(), BaseMessage.class);
switch (message.getType()) {
case MessageType.CHAT:
handleChatMessage(data);
break;
case MessageType.FILE:
handleFileMessage(server, data);
break;
case MessageType.RETURN:
handleReturnMessage(data);
break;
}
}
}
private void handleChatMessage(Object data) {
ChatMessage m = JSON.parseObject(data.toString(), ChatMessage.class);
String tabKey = m.getFrom();// FROM
JComponent comp = Router.getView(ChatRoomView.class).getComponent(ChatRoomView.CHATTABBED);
if (comp instanceof JTabbedPane) {
JTabbedPane tab = (JTabbedPane) comp;
int index = tab.indexOfTab(tabKey);
if (index == -1) {
tab.addTab(tabKey, ResultHolder.get(tabKey).getScrollPane());
}
JTextArea textArea = ResultHolder.get(tabKey).getTextArea();
textArea.setText(new StringBuffer()
.append(textArea.getText()).append(System.lineSeparator()).append(System.lineSeparator())
.append(" [").append(m.getOwner()).append("] : ").append(System.lineSeparator())
.append(m.getContent())
.toString());
// SCROLL TO BOTTOM
textArea.setCaretPosition(textArea.getText().length());
}
}
private void handleFileMessage(Socket server, Object data) {
FileMessage message = JSON.parseObject(data.toString(), FileMessage.class);
if (message.getSize() > 0) {
OutputStream os = null;
try {
if (server != null) {
InputStream is = server.getInputStream();
File dir = new File(ConstantValue.CLIENT_RECEIVE_DIR);
if (!dir.exists()) {
dir.mkdirs();
}
os = new FileOutputStream(
new File(PathUtil.combination(ConstantValue.CLIENT_RECEIVE_DIR, new Date().getTime() + message.getName())));
int total = 0;
while (!server.isClosed()) {
if (is.available() > 0) {
byte[] buff = new byte[ConstantValue.BUFF_SIZE];
int len = -1;
while (is.available() > 0 && (len = is.read(buff)) != -1) {
os.write(buff, 0, len);
total += len;
LoggerUtil.debug("RECEIVE BUFF [" + len + "]");
}
os.flush();
if (total >= message.getSize()) {
LoggerUtil.info("RECEIVE BUFF [OK]");
break;
}
}
}
}
} catch (Exception e) {
LoggerUtil.error("Receive file failed ! " + e.getMessage(), e);
} finally {
if (os != null) {
try {
os.close();
} catch (Exception ignore) {
}
os = null;
}
}
}
}
private void handleReturnMessage(Object data) {
ReturnMessage m = JSON.parseObject(data.toString(), ReturnMessage.class);
if (StringUtil.isNotEmpty(m.getKey())) {
switch (m.getKey()) {
case Key.NOTIFY: // Notify client to update usr list
HF.getHandler(Key.NOTIFY).handle(data);
break;
case Key.LOGIN:
HF.getHandler(Key.LOGIN).handle(data);
break;
case Key.REGISTER:
HF.getHandler(Key.REGISTER).handle(data);
break;
case Key.LISTUSER:
HF.getHandler(Key.LISTUSER).handle(data);
break;
case Key.TIP:
HF.getHandler(Key.TIP).handle(data);
break;
}
}
}
}
[Handler.java、HF.java、ListUserHdl.java...]
Handler組件擔任對服務端前往音訊類型的音訊停止處置，DefaultCallback依據不同的KEY將音訊分發給不同的Handler停止處置，這裡也算一套復雜的工廠組件吧，跟服務端處置接納到的數據設計是相似的，完好的類圖如下：
上面給出這一塊的代碼，為了減少篇幅，將一切Handler完成的代碼收起來。
public interface Handler {
public Object handle(Object obj);
}
public class HF {
public static Handler getHandler(String key) {
switch (key) {
case Key.NOTIFY:
return new NotifyHdl();
case Key.LOGIN:
return new LoginHdl();
case Key.REGISTER:
return new RegisterHdl();
case Key.LISTUSER:
return new ListUserHdl();
case Key.TIP:
return new TipHdl();
}
return null;
}
}
public class ListUserHdl implements Handler {
@Override
public Object handle(Object obj) {
if (obj != null) {
try {
ReturnMessage rm = JSON.parseObject(obj.toString(), ReturnMessage.class);
if (rm.isSuccess() && rm.getContent() != null) {
ClientListUserDTO dto = JSON.parseObject(rm.getContent().toString(), ClientListUserDTO.class);
JComponent comp = Router.getView(ChatRoomView.class).getComponent(ChatRoomView.LISTUSRLIST);
if (comp instanceof JList) {
@SuppressWarnings("unchecked") //
JList<String> listUsrList = (JList<String>) comp;
List<String> listUser = new LinkedList<String>();
listUser.addAll(dto.getListUser());
Collections.sort(listUser);
listUser.add(0, ConstantValue.TO_ALL);
listUsrList.setListData(listUser.toArray(new String[]{}));
}
}
} catch (Exception e) {
LoggerUtil.error("Handle listUsr failed! " + e.getMessage(), e);
}
}
return null;
}
}
public class LoginHdl implements Handler {
@Override
public Object handle(Object obj) {
if (obj != null) {
try {
ReturnMessage rm = JSON.parseObject(obj.toString(),ReturnMessage.class);
if (rm.isSuccess()) {
Router.getView(RegisterAndLoginView.class).trash();
Router.getView(ChatRoomView.class).create().display();
ClientHolder.getClient().keepAlive(rm.getTo()); // KEEP...
} else {
Container container = Router.getView(RegisterAndLoginView.class).container();
if (container != null) {
// show error
JOptionPane.showMessageDialog(container, rm.getMessage());
}
}
} catch (Exception e) {
LoggerUtil.error("Handle login failed! " + e.getMessage(), e);
}
}
return null;
}
}
public class NotifyHdl implements Handler {
@Override
public Object handle(Object obj) {
if (obj != null) {
try {
ReturnMessage rm = JSON.parseObject(obj.toString(), ReturnMessage.class);
if (rm.isSuccess() && rm.getContent() != null) {
ClientNotifyDTO dto = JSON.parseObject(rm.getContent().toString(), ClientNotifyDTO.class);
JComponent comp = Router.getView(ChatRoomView.class).getComponent(ChatRoomView.LISTUSRLIST);
if (comp instanceof JList) {
@SuppressWarnings("unchecked") //
JList<String> listUsrList = (JList<String>) comp;
List<String> listUser = modelToList(listUsrList.getModel());
if (dto.isFlag()) {
if (!listUser.contains(dto.getUsername())) {
listUser.add(dto.getUsername());
listUser.remove(ConstantValue.TO_ALL);
Collections.sort(listUser);
listUser.add(0, ConstantValue.TO_ALL);
}
} else {
listUser.remove(dto.getUsername());
}
listUsrList.setListData(listUser.toArray(new String[]{}));
}
}
} catch (Exception e) {
LoggerUtil.error("Handle nofity failed! " + e.getMessage(), e);
}
}
return null;
}
private List<String> modelToList(ListModel<String> listModel) {
List<String> list = new LinkedList<String>();
if (listModel != null) {
for (int i = 0; i < listModel.getSize(); i++) {
list.add(listModel.getElementAt(i));
}
}
return list;
}
}
public class RegisterHdl implements Handler {
@Override
public Object handle(Object obj) {
if (obj != null) {
try {
ReturnMessage rm = JSON.parseObject(obj.toString(),ReturnMessage.class);
Container container = Router.getView(RegisterAndLoginView.class).container();
if (container != null) {
if (rm.isSuccess()) {
JOptionPane.showMessageDialog(container, rm.getContent());
} else {
JOptionPane.showMessageDialog(container, rm.getMessage());
}
}
} catch (Exception e) {
LoggerUtil.error("Handle register failed! " + e.getMessage(), e);
}
}
return null;
}
}
public class TipHdl implements Handler {
@Override
public Object handle(Object obj) {
if (obj != null) {
try {
ReturnMessage m = JSON.parseObject(obj.toString(), ReturnMessage.class);
if (m.isSuccess() && m.getContent() != null) {
String tabKey = m.getFrom();
String tip = m.getContent().toString();
JComponent comp = Router.getView(ChatRoomView.class).getComponent(ChatRoomView.CHATTABBED);
if (comp instanceof JTabbedPane) {
JTabbedPane tab = (JTabbedPane) comp;
int index = tab.indexOfTab(tabKey);
if (index == -1) {
tab.addTab(tabKey, ResultHolder.get(tabKey).getScrollPane());
}
JTextArea textArea = ResultHolder.get(tabKey).getTextArea();
textArea.setText(new StringBuffer()
.append(textArea.getText()).append(System.lineSeparator()).append(System.lineSeparator())
.append(" [").append(m.getOwner()).append("] : ").append(System.lineSeparator())
.append(tip)
.toString());
// SCROLL TO BOTTOM
textArea.setCaretPosition(textArea.getText().length());
}
}
} catch (Exception e) {
LoggerUtil.error("Handle tip failed! " + e.getMessage(), e);
}
}
return null;
}
}
關於Socket通訊模塊還有一個類，那就是ClientHolder，這個類用於存儲以後Client，跟服務端的SocketHolder是相似的。
/**
* @author yaolin
*/
public class ClientHolder {
public static Client client;
public static Client getClient() {
return client;
}
public static void setClient(Client client) {
ClientHolder.client = client;
}
}
UI模塊詳細完成：
下面記載了socket通訊模塊的設計，接上去記載一下UI的設計模塊，我不計劃自己寫UI，畢竟自己寫出來的太丑了，所當前期能夠會叫同窗或冤家幫助敲一下，所以我將UI的事情處置都交由Action去處置，將UI設計和事情呼應復雜別離，一切UI承繼JFrame並完成View接口，下面的Handler完成類經過Router獲取（存在則直接前往，不存在則創立並存儲）指定的UI，View中提供了UI的創立create()、獲取container()、獲取UI中的組件getComponent()，顯示display()，回收trash()；ResultWrapper和ResultHolder只是為了創立和存儲聊天選項卡。設計如下：
[Router.java、View.java]
一切UI承繼JFrame並完成View接口，Handler完成類經過Router獲取（存在則直接前往，不存在則創立並存儲）指定的UI，View中提供了UI的創立create()、獲取container()、獲取UI中的組件getComponent()，顯示display()，回收trash()，詳細完成如下：
/**
* View 路由
* @author yaolin
*/
public class Router {
private static Map<String, View> listRoute = new HashMap<String,View>();
public static View getView(Class<?> clazz) {
View v = listRoute.get(clazz.getName());
if (v == null) {
try {
v = (View) Class.forName(clazz.getName()).newInstance();
listRoute.put(clazz.getName(), v);
} catch (Exception e) {
LoggerUtil.error("Create view failed! " + e.getMessage(), e);
}
}
return v;
}
}
/**
* 一切界面的標准接口
* @author yaolin
*
*/
public interface View {
/**
*
*/
public View create();
/**
*
*/
public Container container();
/**
* @param key
*/
public JComponent getComponent(String key);
/**
*
*/
public void display();
/**
*
*/
public void trash();
}
[RegisterAndLoginView.java、ChatRoomView.java]
由於不想自己寫UI，我這裡只是復雜的寫了兩個UI界面，辨別是注冊和登陸界面、聊天界面，這裡給出兩個丑丑的界面：
注冊登錄界面
聊天界面
上面給出這兩個這界面的詳細代碼：
/**
* 注冊、登陸
* @author yaolin
*/
public class RegisterAndLoginView extends JFrame implements View {
private static final long serialVersionUID = 6322088074312546736L;
private final RegisterAndLoginAction action = new RegisterAndLoginAction();
private static boolean CREATE = false;
@Override
public View create() {
if (! CREATE) {
init();
CREATE = true;
}
return this;
}
public Container container() {
create();
return getContentPane();
}
@Override
public JComponent getComponent(String key) {
return null;
}
@Override
public void display() {
setVisible(true);
}
@Override
public void trash() {
dispose();
}
private void init() {
// Attribute
setSize(500, 300);
setResizable(false);
setLocationRelativeTo(null);
// Container
JPanel panel = new JPanel();
panel.setLayout(null);
// Component
// username
JLabel lbUsername = new JLabel(I18N.TEXT_USERNAME);
lbUsername.setBounds(100, 80, 200, 30);
final JTextField tfUsername = new JTextField();
tfUsername.setBounds(150, 80, 230, 30);
panel.add(lbUsername);
panel.add(tfUsername);
// passsword
JLabel lbPassword = new JLabel(I18N.TEXT_PASSWORD);
lbPassword.setBounds(100, 120, 200, 30);
final JPasswordField pfPassword = new JPasswordField();
pfPassword.setBounds(150, 120, 230, 30);
panel.add(lbPassword);
panel.add(pfPassword);
// btnRegister
JButton btnRegister = new JButton(I18N.BTN_REGISTER);
btnRegister.setBounds(100, 175, 80, 30);
// btnLogin
final JButton btnLogin = new JButton(I18N.BTN_LOGIN);
btnLogin.setBounds(200, 175, 80, 30);
// btnCancel
JButton btnExit = new JButton(I18N.BTN_EXIT);
btnExit.setBounds(300, 175, 80, 30);
panel.add(btnRegister);
panel.add(btnLogin);
panel.add(btnExit);
// Event
pfPassword.addKeyListener(new KeyAdapter() {
public void keyPressed(final KeyEvent e) {
if (e.getKeyCode() == KeyEvent.VK_ENTER)
btnLogin.doClick();
}
});// end of addKeyListener
btnRegister.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent e) {
if (StringUtil.isEmpty(tfUsername.getText())
|| StringUtil.isEmpty(new String(pfPassword.getPassword()))) {
JOptionPane.showMessageDialog(getContentPane(), I18N.INFO_REGISTER_EMPTY_DATA);
return ;
}
action.handleRegister(tfUsername.getText(), new String(pfPassword.getPassword()));
}
});// end of addActionListener
btnLogin.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent e) {
if (StringUtil.isEmpty(tfUsername.getText())
|| StringUtil.isEmpty(new String(pfPassword.getPassword()))) {
JOptionPane.showMessageDialog(getContentPane(), I18N.INFO_LOGIN_EMPTY_DATA);
return ;
}
action.handleLogin(tfUsername.getText(), new String(pfPassword.getPassword()));
}
});// end of addActionListener
btnExit.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent e) {
System.exit(0);
}
});// end of addActionListener
getContentPane().add(panel);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
}
/**
* Client 聊天窗口
*
* @author yaolin
*/
public class ChatRoomView extends JFrame implements View {
private static final long serialVersionUID = -4515831172899054818L;
public static final String LISTUSRLIST = "LISTUSRLIST";
public static final String CHATTABBED = "CHATTABBED";
private static boolean CREATE = false;
private ChatRoomAction action = new ChatRoomAction();
private JList<String> listUsrList = null;
private JTabbedPane chatTabbed = null;
@Override
public View create() {
if (!CREATE) {
init();
CREATE = true;
}
return this;
}
public Container container() {
create();
return getContentPane();
}
@Override
public JComponent getComponent(String key) {
create();
switch (key) {
case LISTUSRLIST:
return listUsrList;
case CHATTABBED:
return chatTabbed;
}
return null;
}
@Override
public void display() {
setVisible(true);
}
@Override
public void trash() {
dispose();
}
public void init() {
setTitle(I18N.TEXT_APP_NAME);
setSize(800, 600);
setResizable(false);
setLocationRelativeTo(null);
setLayout(new BorderLayout());
add(createChatPanel(), BorderLayout.CENTER);
add(createUsrListView(), BorderLayout.EAST);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
private JComponent createChatPanel() {
// FILE SELECTOR
final JFileChooser fileChooser = new JFileChooser();
JPanel panel = new JPanel(new BorderLayout());
// CENTER
chatTabbed = new JTabbedPane();
chatTabbed.addTab(ConstantValue.TO_ALL, ResultHolder.get(ConstantValue.TO_ALL).getScrollPane());
panel.add(chatTabbed, BorderLayout.CENTER);
// SOUTH
JPanel south = new JPanel(new BorderLayout());
// SOUTH - FILE
JPanel middle = new JPanel(new BorderLayout());
middle.add(new JLabel(), BorderLayout.CENTER); // JUST FOR PADDING
JButton btnUpload = new JButton(I18N.BTN_SEND_FILE);
middle.add(btnUpload, BorderLayout.EAST);
south.add(middle, BorderLayout.NORTH);
// SOUTH - TEXTAREA
final JTextArea taSend = new JTextArea();
taSend.setCaretColor(Color.BLUE);
taSend.setMargin(new Insets(10, 10, 10, 10));
taSend.setRows(10);
south.add(taSend, BorderLayout.CENTER);
// SOUTH - BTN
JPanel bottom = new JPanel(new BorderLayout());
bottom.add(new JLabel(), BorderLayout.CENTER); // JUST FOR PADDING
JButton btnSend = new JButton(I18N.BTN_SEND);
bottom.add(btnSend, BorderLayout.EAST);
south.add(bottom, BorderLayout.SOUTH);
btnUpload.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent e) {
if (! ConstantValue.TO_ALL.equals(chatTabbed.getTitleAt(chatTabbed.getSelectedIndex()))) {
int returnVal = fileChooser.showOpenDialog(ChatRoomView.this);
if (returnVal == JFileChooser.APPROVE_OPTION) {
File file = fileChooser.getSelectedFile();
action.upload(chatTabbed.getTitleAt(chatTabbed.getSelectedIndex()), file);
}
} else {
JOptionPane.showMessageDialog(getContentPane(), I18N.INFO_FILE_TO_ALL_ERROR);
}
}
});
btnSend.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent e) {
if (StringUtil.isNotEmpty(taSend.getText())) {
action.send(chatTabbed.getTitleAt(chatTabbed.getSelectedIndex()), taSend.getText());
taSend.setText(null);
}
}
});
panel.add(south, BorderLayout.SOUTH);
return panel;
}
private JComponent createUsrListView() {
listUsrList = new JList<String>();
listUsrList.setBorder(new LineBorder(Color.BLUE));
listUsrList.setListData(new String[] { ConstantValue.TO_ALL });
listUsrList.setFixedCellWidth(200);
listUsrList.setFixedCellHeight(30);
listUsrList.addListSelectionListener(new ListSelectionListener() {
@Override
public void valueChanged(ListSelectionEvent e) { // chat to
if (chatTabbed.indexOfTab(listUsrList.getSelectedValue()) == -1
&& listUsrList.getSelectedValue() != null
&& !listUsrList.getSelectedValue().equals(ClientHolder.getClient().getFrom())) {
chatTabbed.addTab(listUsrList.getSelectedValue(),
ResultHolder.get(listUsrList.getSelectedValue()).getScrollPane());
chatTabbed.setSelectedIndex(chatTabbed.indexOfTab(listUsrList.getSelectedValue()));
}
}
});
return listUsrList;
}
}
[RegisterAndLoginAction.java、ChatRoomAction.java]
這裡UI的事情處置都交由Action去處置，將UI設計和事情呼應復雜別離，RegisterAndLoginView的事情由RegisterAndLoginAction處置，ChatRoomView的事情由ChatRoomAction處置。詳細完成如下：
public class RegisterAndLoginAction {
public void handleRegister(String username, String password) {
if (StringUtil.isEmpty(username) || StringUtil.isEmpty(password)) {
return;
}
RegisterMessage message = new RegisterMessage()
.setUsername(username)
.setPassword(password);
message.setFrom(username);
SendHelper.send(ClientHolder.getClient().getSocket(), message);
}
public void handleLogin(String username, String password) {
if (StringUtil.isEmpty(username) || StringUtil.isEmpty(password)) {
return;
}
LoginMessage message = new LoginMessage()
.setUsername(username)
.setPassword(password);
message.setFrom(username);
SendHelper.send(ClientHolder.getClient().getSocket(), message);
}
}
關於UI設計還有兩個類，辨別是ResultHolder和ResultWrapper，ResultWrapper和ResultHolder只是為了創立和存儲聊天選項卡，詳細完成如下：
public class ResultWrapper {
private JScrollPane scrollPane;
private JTextArea textArea;
public ResultWrapper(JScrollPane scrollPane, JTextArea textArea) {
this.scrollPane = scrollPane;
this.textArea = textArea;
}
public JScrollPane getScrollPane() {
return scrollPane;
}
public void setScrollPane(JScrollPane scrollPane) {
this.scrollPane = scrollPane;
}
public JTextArea getTextArea() {
return textArea;
}
public void setTextArea(JTextArea textArea) {
this.textArea = textArea;
}
}
public class ResultHolder {
private static Map<String, ResultWrapper> listResultWrapper = new HashMap<String,ResultWrapper>();
public static void put(String key, ResultWrapper wrapper) {
listResultWrapper.put(key, wrapper);
}
public static ResultWrapper get(String key) {
ResultWrapper wrapper = listResultWrapper.get(key);
if (wrapper == null) {
wrapper = create();
put(key, wrapper);
}
return wrapper;
}
private static ResultWrapper create() {
JTextArea resultTextArea = new JTextArea();
resultTextArea.setEditable(false);
resultTextArea.setBorder(new LineBorder(Color.BLUE));
JScrollPane scrollPane = new JScrollPane(resultTextArea);
scrollPane.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_NEVER);
scrollPane.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_AS_NEEDED);
ResultWrapper wrapper = new ResultWrapper(scrollPane, resultTextArea);
return wrapper;
}
}
最後的最後給出，客戶端運轉的入口：
/**
*
* @author yaolin
*
*/
public class NiloayChat {
public static void main(String[] args) {
View v = Router.getView(RegisterAndLoginView.class).create();
try {
v.display();
Client client = new Client(new DefaultCallback());
client.start();
ClientHolder.setClient(client);
} catch (IOException e) {
JOptionPane.showMessageDialog(v.container(), e.getMessage());
}
}
}
demo下載地址：demo
以上就是本文的全部內容，希望對大家的學習有所協助，也希望大家多多支持。
