[자바/JAVA] nio 를 이용한 소켓 서버 (GUI 연동) 2.0 Version 5부 (클라이언트부분)

안녕하세요 jsieun 입니다.

이번에는 드디어 마지막 클라이언트 부분이 되겠습니다.

사실 클라이언트는 좀 대충 만든 감이 없지 않아 있습니다..ㅡㅡ;;

일종의 테스트용으로 만든것이기 때문이라는 핑계가 있습니다 ㅋ_ㅋ

그럼 소스를 보도록 하겠습니다.

package JSieunPlatform;
/*
 * 2017_07_09 2.0Version.
 * Copyright 2017. J.sieun all rights reserved.
 * 마음껏 사용하도 되나, 제이름은 적어주시길 바랍니다.
 * */
import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.GridLayout;
import java.awt.Toolkit;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.AdjustmentEvent;
import java.awt.event.AdjustmentListener;
import java.awt.event.ItemEvent;
import java.awt.event.ItemListener;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.StandardSocketOptions;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Iterator;

import javax.swing.BorderFactory;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollBar;
import javax.swing.JScrollPane;
import javax.swing.JTextField;
import javax.swing.JTextPane;
import javax.swing.text.SimpleAttributeSet;
import javax.swing.text.StyledDocument;

@SuppressWarnings("serial")
public class JClient extends JFrame implements ActionListener, AdjustmentListener, ItemListener, Runnable, KeyListener {
 //================
 // 변수들.
 //================
 private JLabel nameLabel;
 private JButton conectButton, disconectButton, packetButton;
 private JButton loginButton, whisperButton,groupWaitButton,groupSendButton;
 // 상태창 변수들
 private JLabel stateLabel;
 private JScrollBar scrollBar;
 private JTextPane statePane;
 private SimpleAttributeSet attriState;
 private StyledDocument docState;
 // 메시지 입력 변수들
 private JTextField editText;
 private JTextField nameText;
 private JButton sendButton;

 // 소켓채널
 private Selector Selector = null;
 private SocketChannel Client = null;
 private InetSocketAddress connectAddress;
 private String address = "127.0.0.1";
 private int port = 20000;
 private boolean bStart = true;

 // RecvBuf
 private ByteBuffer RecvBuf;
 // 패킷
 private JNetPacket packet = null;
 // 유저 이름
 private String UserName = "";

 public JClient() {
  super("J.Sieun Client");
  connectAddress  = new InetSocketAddress(address, port);
  packet     = new JNetPacket();
  RecvBuf     = ByteBuffer.allocate(1000);
 }

 public void initialize() {
  // 제목
  JPanel mainPanel  = new JPanel();
  nameLabel    = new JLabel("Test_Client");
  mainPanel.add(nameLabel);

  // 버튼들
  JPanel buttonPanel  = new JPanel(new GridLayout(8, 1));

  conectButton    = new JButton("연결");
  disconectButton   = new JButton("연결해제");
  loginButton     = new JButton("로그인");
  whisperButton    = new JButton("귓속말");
  packetButton    = new JButton("패킷전송");
  groupWaitButton   = new JButton("그룹대기");
  groupSendButton   = new JButton("그룹전송");
  
  conectButton.addActionListener(this);
  disconectButton.addActionListener(this);
  loginButton.addActionListener(this);
  whisperButton.addActionListener(this);
  packetButton.addActionListener(this);
  groupWaitButton.addActionListener(this);
  groupSendButton.addActionListener(this);
  
  buttonPanel.add(conectButton);
  buttonPanel.add(disconectButton);
  buttonPanel.add(loginButton);
  buttonPanel.add(whisperButton);
  buttonPanel.add(packetButton);
  buttonPanel.add(groupWaitButton);
  buttonPanel.add(groupSendButton);
  // 상태창
  JPanel statePanel  = new JPanel(new BorderLayout());
  stateLabel    = new JLabel("\tState Message\t", JLabel.CENTER);

  statePane = new JTextPane();
  statePane.setBorder(BorderFactory.createRaisedBevelBorder());
  statePane.setEditable(false);

  JScrollPane scroll = new JScrollPane(statePane, JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED,
    JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
  scroll.setOpaque(false);

  scrollBar  = scroll.getVerticalScrollBar();
  docState  = statePane.getStyledDocument();
  statePanel.add(stateLabel, "North");
  statePanel.add(scroll, "Center");
  // 메시지 입력창
  JPanel msgPanel  = new JPanel();
  editText     = new JTextField(15);
  nameText    = new JTextField(8);
  sendButton    = new JButton("보내기");
  sendButton.addActionListener(this);
  msgPanel.add(nameText);
  msgPanel.add(editText);
  msgPanel.add(sendButton);

  // 최종 추가
  getContentPane().add(mainPanel, "North");
  getContentPane().add(statePanel, "Center");
  getContentPane().add(msgPanel, "South");
  getContentPane().add(buttonPanel, "East");

  setDefaultCloseOperation(EXIT_ON_CLOSE);
  Toolkit kit = getToolkit();
  Dimension dmen = kit.getScreenSize();
  setLocation((int) ((dmen.width - getSize().width) / 2), (int) ((dmen.height - getSize().height) / 2));
  setSize(700, 400);
  setResizable(false);
  setVisible(true);
 }

 @Override
 public void itemStateChanged(ItemEvent arg0) {
  // TODO Auto-generated method stub

 }

 @Override
 public void adjustmentValueChanged(AdjustmentEvent arg0) {
  // TODO Auto-generated method stub

 }

 @Override
 public void actionPerformed(ActionEvent e) {
  // TODO Auto-generated method stub
  Object o = e.getSource();
  if (o.equals(conectButton)) {
   try {
    Connect();
   } catch (Exception ex) {
    stateMsg("서버연결 에러 : " + ex.getMessage());
   }
   conectButton.setEnabled(false);
  }
  if(o.equals(disconectButton))
  {
   packet.Clear();
   packet.Type(JNetPacket.DISCONNECT);
   packet.Add(UserName);
   Send(packet);
   stateMsg("연결을 종료합니다. \n");
   disconectButton.setEnabled(false);
  }
  if (o.equals(packetButton)) {
   packet.Clear();
   packet.Type(JNetPacket.TESTPACKET);
   packet.Add("패킷테스트");
   packet.Add(1001001);
   Send(packet);
  }
  if (o.equals(sendButton)) {
   packet.Clear();
   packet.Type(JNetPacket.CHAT);
   packet.Add(UserName);
   packet.Add("" + editText.getText());
   editText.setText("");
   Send(packet);
  }
  if (o.equals(loginButton)) {
   packet.Clear();
   packet.Type(JNetPacket.LOGIN);
   packet.Add("" + nameText.getText());
   UserName = nameText.getText();
   nameText.setText("");
   nameLabel.setText("" + UserName + " 님");
   Send(packet);
   loginButton.setEnabled(false);
  }
  if (o.equals(whisperButton)) {
   packet.Clear();
   packet.Type(JNetPacket.WHISPER);
   packet.Add(UserName);
   packet.Add("" + nameText.getText());
   packet.Add("" + editText.getText());
   nameText.setText("");
   editText.setText("");
   Send(packet);
  }
  if(o.equals(groupWaitButton))
  {
   groupWaitButton.setEnabled(false);
   //그룹대기
   packet.Clear();
   packet.Type(JNetPacket.GROUPWAIT);
   packet.Add(UserName);
   Send(packet);
  }
  if(o.equals(groupSendButton))
  {
   //그룹전송
   packet.Clear();
   packet.Type(JNetPacket.GROUPSEND);
   packet.Add(UserName);
   packet.Add(""+editText.getText());
   editText.setText("");
   Send(packet);
  }
 }

 @Override
 public void keyPressed(KeyEvent e) {
  /*
   * // TODO Auto-generated method stub if(e.getKeyCode() ==
   * KeyEvent.VK_ENTER) { packet.Clear(); packet.Type(JPacket.CHAT);
   * packet.Add(""+editText.getText()); editText.setText("");
   * Send(packet); }
   */
 }

 @Override
 public void keyTyped(KeyEvent e) {
  // TODO Auto-generated method stub
  int keycode = e.getKeyCode();
 }

 @Override
 public void keyReleased(KeyEvent e) {
  // TODO Auto-generated method stub
 }

 private void Connect() {
  try {
   Client = SocketChannel.open();
   //논블로킹,보내고 받는사이즈 1000,서버와 계속해서 유지,해체시 바로 데이터들 삭제.
   Client.configureBlocking(false);
   Client.setOption(StandardSocketOptions.SO_RCVBUF, 128*1000);
   Client.setOption(StandardSocketOptions.SO_SNDBUF, 128*1000);
   Client.setOption(StandardSocketOptions.SO_KEEPALIVE, true);
   Client.setOption(StandardSocketOptions.SO_LINGER, 0);
   // 요청연결
   Client.connect(connectAddress);
   stateMsg("연결완료 \n");
   Thread thread = new Thread(this);
   thread.start();
  } catch (Exception e) {
   System.out.println("Connect Error : " + e.getMessage());
  }
 }

 public void Send(JNetPacket data) {
  try {
   Client.write(data.getBuf());
   // Thread.sleep(10);
  } catch (Exception e) {
   System.out.println("Send Error : " + e.getMessage());
  }

 }

 public void run() {
  try {
   Selector = java.nio.channels.Selector.open();
   Client.register(Selector, SelectionKey.OP_CONNECT);
  } catch (Exception ex) {
   stateMsg("Run Error : " + ex.getMessage() + "\n");
  }
  while (bStart) {
   try {
    Selector.select();
    Iterator<SelectionKey> keys = Selector.selectedKeys().iterator();
    while (keys.hasNext()) {
     SelectionKey key = keys.next();
     keys.remove();
     if (key.isConnectable()) {
      if (Client.finishConnect()) {
       key.interestOps(SelectionKey.OP_READ);
      } else {
       key.cancel();
      }
     } else if (key.isReadable()) {
      Client.read(RecvBuf);
      RecvEvt();
     }
    }
   } catch (Exception e) {
    stateMsg("Recv Error :" + e.getMessage() + "\n");
    this.bStart = false;
   }
  }
 }

 public void RecvEvt() {
  RecvBuf.flip();
  packet.Clear();
  String ClntMsg_1,ClntMsg_2,ClntMsg_3,ClntMsg_4,ClntMsg_5 = "";
  short Type = RecvBuf.getShort();
  switch (Type) {
  case JNetPacket.LOGIN :
   stateMsg("서버와 접속이 완료되었습니다. \n");
   RecvBuf.clear();
   break;
  case JNetPacket.LOGININFOR :
   stateMsg("*****로그인 정보*****\n");
   LoginInfor(RecvBuf);
   RecvBuf.clear();
   break;
  case JNetPacket.DISCONNECT :
   ClntMsg_1 = JNetPacket.RecvOut(RecvBuf);
   stateMsg(ClntMsg_1 + "님이 로그아웃하였습니다. \n");
   RecvBuf.clear();
   break;
  case JNetPacket.CHAT :
   ClntMsg_1 = JNetPacket.RecvOut(RecvBuf);
   ClntMsg_2 = JNetPacket.RecvOut(RecvBuf);
   stateMsg("[" + ClntMsg_1 + "] 님의 말 : " + ClntMsg_2 + "\n");
   RecvBuf.clear();
   break;
  case JNetPacket.GROUPSEND :
   ClntMsg_1 = JNetPacket.RecvOut(RecvBuf);
   ClntMsg_2 = JNetPacket.RecvOut(RecvBuf);
   stateMsg("그룹Msg : ["+ClntMsg_1+"] 님의 말 : " + ClntMsg_2 + "\n");
   RecvBuf.clear();
   break;
  case JNetPacket.WHISPER :
   ClntMsg_1 = JNetPacket.RecvOut(RecvBuf);
   ClntMsg_2 = JNetPacket.RecvOut(RecvBuf);
   stateMsg("[" + ClntMsg_1 + "] 님의 귓속말 : " + ClntMsg_2 + "\n");
   RecvBuf.clear();
   break;
  case JNetPacket.TESTPACKET :
   ClntMsg_1 = JNetPacket.RecvOut(RecvBuf);
   ClntMsg_2 = JNetPacket.RecvOut(RecvBuf);
   stateMsg("패킷테스트 : " + ClntMsg_1 + " :::: " + ClntMsg_2 + "\n");
   RecvBuf.clear();
   break;
  default:
   RecvBuf.clear();
   break;
  }
 }

 // 상태메시지
 public void stateMsg(String msg) {
  try {
   attriState = new SimpleAttributeSet();
   statePane.setCaretPosition(docState.getEndPosition().getOffset() - 1);
   docState.insertString(statePane.getCaretPosition(), msg, attriState);
   scrollBar.addAdjustmentListener(this);
  } catch (Exception e) {
   String _errorMsg = "*상태메시지 에러발생!!*";
   JOptionPane.showMessageDialog(null, _errorMsg, "JServer", JOptionPane.INFORMATION_MESSAGE);
  }
 }

 // 로그인 정보
 public void LoginInfor(ByteBuffer RecvBuf) {
  String strSize = JNetPacket.RecvOut(RecvBuf);
  int Size = Integer.parseInt(strSize);
  for (int i = 0; i < Size; i++) {
   stateMsg((i  + 1 )+ "  " + JNetPacket.RecvOut(RecvBuf) + " 님 ");
  }
  stateMsg("\n");
 }

 public static void main(String[] args) {
  // TODO Auto-generated method stub
  JClient test = new JClient();
  test.initialize();
 }

}

다른건 다필요 없고, 사용자에 맞게 할려면 데이터를 보내고 싶다?

packet.Clear();

packet.Type();

packet.Add();

packet.Add();

Send(packet);

이 순서대로 하시면 되겠습니다.

그리고 서버한테 데이터를 받았을시 처리하는 부분은

RecvEvt 가 되겠습니다.

여기서 서버에서 설명드렸듯이 사용자 입맛대로 수정&추가 하셔서 코딩을 하면 되겠습니다.

클라이언트 부분에 설명이 좀 부족한 면이 없지 않아 있는데

그이유는 클라이언트는 사용자에 맞게 설정되기때문에 Connect 하는 부분과 서버에게 보내거나, 받는 것을 처리하는 부분에 대해서 알고 있기만 하면 되기 때문에 상관 없을듯 합니다 ㅋ_ㅋ

그럼 포스팅을 마치도록 하겠습니다.

감사합니다.