채팅 프로그램 질문

Question

Manager.java import java.io.PrintWriter; import java.net.Socket; import java.util.ArrayList; public class Manager { private ArrayList ar = new ArrayList<>(); public void add(Socket socket) { ar.add(socket); } public void remove(Socket socket) { ar.remove(socket); } public synchronized void sendMessage(String message) { PrintWriter writer = null; Socket socket; for (int i = 0; i < ar.size(); i++) { socket = (Socket) ar.get(i); try { writer = new PrintWriter(socket.getOutputStream(), true); } catch(Exception e) { e.printStackTrace(); } if (writer != null) { writer.println(message); } } } public synchronized void sendInformation() { String information = "현재 채팅 인원 : " + ar.size(); System.out.println(information); try { sendMessage(information); } catch (Exception e) { e.printStackTrace(); } } } Chat.java import java.net.*; import java.io.*; public class Chat extends Thread { private Socket socket; private BufferedReader reader; private Manager manager; public Chat(Socket socket, Manager manager) { this.socket = socket; this.manager = manager; } public void run() { try { reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); String message; try { while((message = reader.readLine()) != null) { System.out.println(message); manager.sendMessage(message); } } catch (SocketException e) { e.getStackTrace(); } } catch (Exception e) { e.printStackTrace(); } try { exitChat(); } catch (Exception e) { e.printStackTrace(); } } private void exitChat() { try { reader.close(); socket.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("종료되었습니다."); manager.remove(socket); try { manager.sendInformation(); } catch (Exception e) { e.printStackTrace(); } } } Server.java package roomObject; import java.net.ServerSocket; import java.net.Socket; import javax.swing.*; public class Server extends JFrame{ private ServerSocket server; private Socket socket; private Manager manager = new Manager(); private Chat chat; public void start() { try { server = new ServerSocket(1009); System.out.println("서버 소켓이 생성되었습니다."); while(true) { socket = server.accept(); manager.add(socket); chat = new Chat(socket, manager); chat.start(); manager.sendInformation(); } } catch(Exception e) { e.printStackTrace(); } } } Main.java public class Main { public static void main(String[] args) { // TODO Auto-generated method stub Server server = new Server(); server.start(); } } 여기까지가 서버------------------------------------------------------------------------------------- Room.java import java.io.PrintWriter; import javax.swing.JFrame; import javax.swing.JTextField; public class Room extends JFrame{ private Client client; private String name; public void setChatName(String name) { this.name = name; } } ChattingRoom.java import java.awt.List; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.util.ArrayList; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; public class ChattingRoom extends JFrame{ private JButton entryButton = new JButton("입장"); private JButton exitButton = new JButton("나가기"); private JButton createButton = new JButton("만들기"); private JLabel chatNameLabel = new JLabel("채팅방 이름"); private List waitingRoomList = new List(); private JTextField chatNameField = new JTextField(); private Client client = new Client(); private ArrayList roomArr = new ArrayList<>(); public ChattingRoom() { setTitle("대기실"); setSize(740, 480); //setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setLocationRelativeTo(null); setLayout(null); waitingRoomList.setBounds(10, 10, 700, 300); add(waitingRoomList); entryButton.setBounds(32, 332, 146, 51); add(entryButton); createButton.setBounds(219, 332, 146, 51); add(createButton); exitButton.setBounds(415, 332, 146, 51); add(exitButton); chatNameField.setBounds(178, 393, 532, 38); add(chatNameField); chatNameLabel.setBounds(42, 393, 100, 38); add(chatNameLabel); buttonPressed(); setVisible(true); } public void buttonPressed() { entryButton.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { // TODO Auto-generated method stub //client.connect(); } }); createButton.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { // TODO Auto-generated method stub Room room = new Room(); waitingRoomList.add(chatNameField.getText()); room.setName(chatNameField.getText()); roomArr.add(room); client.connect(); client.draw(); } }); exitButton.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { // TODO Auto-generated method stub System.exit(0); } }); } } Client.java import java.awt.List; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.util.ArrayList; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; public class Client extends JFrame implements Runnable { private JTextArea textArea = new JTextArea(); private JTextField nameField = new JTextField(); private JTextField textField = new JTextField(); private JScrollPane scroll; private JButton entryButton = new JButton("입장"); private JButton exitButton = new JButton("나가기"); private JButton createButton = new JButton("만들기"); private JLabel chatNameLabel = new JLabel("채팅방 이름"); private JLabel nickNameLabel = new JLabel("닉네임 : "); private List waitingRoomList = new List(); private JTextField chatNameField = new JTextField(); private JLabel label = new JLabel("접속자 목록"); private JButton button = new JButton("입력"); private List list = new List(); private String nickName; private ArrayList roomArr = new ArrayList<>(); private BufferedReader reader; private Socket socket; private PrintWriter writer; public void draw() { setTitle("클라이언트"); setSize(874, 481); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setLocationRelativeTo(null); setLayout(null); textArea.setBounds(10, 10, 700, 300); add(textArea); textArea.setEditable(false); scroll = new JScrollPane(textArea); scroll.setBounds(3, 3, 700, 300); add(scroll); nameField.setBounds(124, 330, 200, 40); add(nameField); textField.setBounds(10, 380, 700, 40); add(textField); label.setBounds(728, 27, 106, 23); add(label); list.setBounds(728, 60, 118, 245); add(list); // nickNameLabel.setBounds(728, 27, 106, 23); // add(nickNameLabel); button.setBounds(26, 336, 79, 27); add(button); setVisible(true); button.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { // TODO Auto-generated method stub nickName = nameField.getText(); list.add(nickName); nameField.setEditable(false); } }); textField.addActionListener(new ActionListener() { @Override public void actionPerformed(ActionEvent e) { try { writer.println(nickName + " : " + textField.getText()); textField.setText(""); } catch (Exception ex) { ex.printStackTrace(); } } }); } public void run() { while (true) { try { textArea.append(reader.readLine() + " "); scroll.getVerticalScrollBar().setValue(scroll.getVerticalScrollBar().getMaximum()); } catch (Exception e) { e.printStackTrace(); } } } public void connect() { try { socket = new Socket("10.0.75.1", 1009); reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); writer = new PrintWriter(socket.getOutputStream(), true); Thread thread = new Thread(this); thread.start(); } catch(Exception e) { e.printStackTrace(); } } } ClientMain.java public class ClientMain { public static void main(String[] args) { ChattingRoom ch = new ChattingRoom(); } } 채팅룸을 만들고 싶습니다 ㅠㅠㅠㅠ 그런데 자꾸 A 룸으로 들어가든 B 룸으로 들어가든 서로 소통?이 됩니다.. A룸에 입장된 사람들끼리만 채팅할 수 있도록 만들고 싶은데... 그리고 client를 새로 실행할 때마다, Room 리스트가 초기화 되더군요... 네트워킹 프로그램에 취약해서 채팅프로그램 기초부터 시작했는데 너무 막막하네요 ㅠㅠ현재 입장 코드는 아직 구현하지 못했습니다. 이 점 감안해주시면 감사하겠습니다 ㅠㅠ!

채팅 프로그램 질문

0개의 답변

Q&A 목록