fork download

copy

// サーバープログラム
 
import java.io.*;
import java.util.*;
import java.net.*;
 
class UserInfo {
  Socket sock;
  InputStream is;
  OutputStream os;
  String name;
};
 
public class ChatSv {
 
	ServerSocket ssock = null;
	Socket asock = null;
	byte[] buf = new byte[ChatParam.MSIZE];
	UserInfo[] users = new UserInfo[ChatParam.MAX_USERS];
	String str = null;
 
	/* ある参加者からメッセージが送信されてきたら、それ以外の参加者にそのメッセージを転送する */
	class UserProcess extends Thread {
 
		UserInfo userInfo;
 
		UserProcess(UserInfo userInfo){
			this.userInfo = userInfo;
		}
 
		public void run() {
			try {
				while(true){
					if (userInfo.sock != null) {
						int count = userInfo.is.read(buf);
						if (count > 0) {
							sendAll(makeMessage(ChatParam.MSG, new String(buf)));
						}
					}
				}
			}catch(Exception e){
				/* 誰かが抜けた(接続が切れた)場合には他の参加者に抜けたことを伝える */
				sendAll(makeMessage(ChatParam.LEAVE, userInfo.name + "さんが抜けました"));
			}
			try {
				userInfo.sock.close();
				userInfo.sock = null;
			} catch(Exception e) {
				System.out.println(e);
			}
		}
 
	}
 
  public static void main(String[] args) {
		try{
			new ChatSv().start();
		} catch(Exception e) {
			System.out.println(e);
		}
	}
 
  public void start() throws Exception {
 
		ssock = new ServerSocket(ChatParam.PORT);
 
		for (int i = 0; i < ChatParam.MAX_USERS; i++) {
			users[i] = new UserInfo();
			users[i].sock = null;
		};
 
		// このループの仕事は接続受付だけにする
		while (true) {
			try {
				/* クライアントからの接続待ち準備 */
				asock = ssock.accept();
				/* クライアントからの接続受け付け */
				UserInfo newUser = addUser(asock);
 
				if (newUser != null) {
					/* 接続してきたクライアントに参加OKを伝える */
					newUser.os.write(makeMessage(ChatParam.MSG, "チャットに参加しました"));
					new UserProcess(newUser).start();
					/* すでに参加しているクライアントに新しい参加者を伝える */
					sendAll(makeMessage(ChatParam.JOIN, newUser.name + "さんが加わりました"));
				} else {
					/* すでに最大人数に達しているので参加不可をクライアントに伝えて切断処理を行う */
					asock.getOutputStream().write(makeMessage(ChatParam.FULL, "最大人数に達しているため参加できませんでした"));
					Thread.sleep(500);
					asock.close();
				}
 
				// 少なくともこれ以降のクライアントとの通信は並列に行う必要あり
				// (新たな参加者受け付けと参加済みのクライアントからのメッセージ
				// 受信は順序が決まっていないため)
				Thread.currentThread().sleep(100);
 
			} catch(Exception e) {
				e.printStackTrace();
			}
		}
		/* 通信終了処理(上が無限ループなので意味はないが) */
		// ssock.close();
  }
 
	public synchronized byte[] makeMessage(byte param, String message) {
		byte[] result = new byte[ChatParam.MSIZE];
		byte[] messageBytes = (message+"\0").getBytes();
		result[0] = param;
		System.arraycopy(messageBytes, 0, result, 1, (messageBytes.length < ChatParam.MSIZE-1 ) ? messageBytes.length : ChatParam.MSIZE-1);
		return result;
	}
 
	public synchronized UserInfo addUser(Socket s) throws Exception {
		for (int i = 0; i < ChatParam.MAX_USERS; i++) {
			if (users[i].sock == null) {
				// まだ最大人数に達していないので参加OK
				users[i].sock = s;
				users[i].is = s.getInputStream();
				users[i].os = s.getOutputStream();
				users[i].is.read(buf);
				users[i].name = new String(buf, 1, ChatParam.NSIZE).trim(); 
				return users[i];
			}
		}
		return null;
	}
 
	public synchronized void sendAll (byte[] message) {
		if (message == null) {
			return;
		}
		for (int i = 0; i < ChatParam.MAX_USERS; i++) {
			if (users[i].sock != null) {
				try {
					users[i].os.write(message);
				}catch(Exception e){
					System.out.println(e);
				}
			}
		}
	}
}

Main.java:14: error: class ChatSv is public, should be declared in a file named ChatSv.java
public class ChatSv {
       ^
Main.java:18: error: cannot find symbol
	byte[] buf = new byte[ChatParam.MSIZE];
	                      ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:19: error: cannot find symbol
	UserInfo[] users = new UserInfo[ChatParam.MAX_USERS];
	                                ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:37: error: cannot find symbol
							sendAll(makeMessage(ChatParam.MSG, new String(buf)));
							                    ^
  symbol:   variable ChatParam
  location: class ChatSv.UserProcess
Main.java:43: error: cannot find symbol
				sendAll(makeMessage(ChatParam.LEAVE, userInfo.name + "????????"));
				                    ^
  symbol:   variable ChatParam
  location: class ChatSv.UserProcess
Main.java:65: error: cannot find symbol
		ssock = new ServerSocket(ChatParam.PORT);
		                         ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:67: error: cannot find symbol
		for (int i = 0; i < ChatParam.MAX_USERS; i++) {
		                    ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:82: error: cannot find symbol
					newUser.os.write(makeMessage(ChatParam.MSG, "???????????"));
					                             ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:85: error: cannot find symbol
					sendAll(makeMessage(ChatParam.JOIN, newUser.name + "?????????"));
					                    ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:88: error: cannot find symbol
					asock.getOutputStream().write(makeMessage(ChatParam.FULL, "??????????????????????"));
					                                          ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:107: error: cannot find symbol
		byte[] result = new byte[ChatParam.MSIZE];
		                         ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:110: error: cannot find symbol
		System.arraycopy(messageBytes, 0, result, 1, (messageBytes.length < ChatParam.MSIZE-1 ) ? messageBytes.length : ChatParam.MSIZE-1);
		                                                                    ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:110: error: cannot find symbol
		System.arraycopy(messageBytes, 0, result, 1, (messageBytes.length < ChatParam.MSIZE-1 ) ? messageBytes.length : ChatParam.MSIZE-1);
		                                                                                                                ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:115: error: cannot find symbol
		for (int i = 0; i < ChatParam.MAX_USERS; i++) {
		                    ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:122: error: cannot find symbol
				users[i].name = new String(buf, 1, ChatParam.NSIZE).trim(); 
				                                   ^
  symbol:   variable ChatParam
  location: class ChatSv
Main.java:133: error: cannot find symbol
		for (int i = 0; i < ChatParam.MAX_USERS; i++) {
		                    ^
  symbol:   variable ChatParam
  location: class ChatSv
16 errors

Standard output is empty