Skip to content

L
Lab2-chat
Commit f18f2469 authored by Michele Fiori's avatar Michele Fiori
Browse files
Options

Initial Commit

parents
Show whitespace changes
Inline Side-by-side
Showing with 957 additions and 0 deletions
.DS_Store 0 → 100644
View file @ f18f2469
File added
.gradle/buildOutputCleanup/cache.properties 0 → 100644
View file @ f18f2469
#Sun Apr 07 16:20:42 CEST 2024
gradle.version=6.7
.idea/.gitignore 0 → 100644
View file @ f18f2469
# Default ignored files
/shelf/
/workspace.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml
.idea/.name 0 → 100644
View file @ f18f2469
setup_SDP
\ No newline at end of file
.idea/compiler.xml 0 → 100644
View file @ f18f2469
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<bytecodeTargetLevel target="15" />
</component>
</project>
\ No newline at end of file
.idea/gradle.xml 0 → 100644
View file @ f18f2469
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="GradleMigrationSettings" migrationVersion="1" />
<component name="GradleSettings">
<option name="linkedExternalProjectsSettings">
<GradleProjectSettings>
<option name="externalProjectPath" value="$PROJECT_DIR$" />
<option name="modules">
<set>
<option value="$PROJECT_DIR$" />
</set>
</option>
</GradleProjectSettings>
</option>
</component>
</project>
\ No newline at end of file
.idea/jarRepositories.xml 0 → 100644
View file @ f18f2469
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
<remote-repository>
<option name="id" value="MavenRepo" />
<option name="name" value="MavenRepo" />
<option name="url" value="https://repo.maven.apache.org/maven2/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
.idea/misc.xml 0 → 100644
View file @ f18f2469
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="ProjectRootManager" version="2" languageLevel="JDK_15" default="true" project-jdk-name="azul-15" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
.idea/uiDesigner.xml 0 → 100644
View file @ f18f2469
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Palette2">
<group name="Swing">
<item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
</item>
<item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
</item>
<item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
<default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
</item>
<item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
<initial-values>
<property name="text" value="Button" />
</initial-values>
</item>
<item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="RadioButton" />
</initial-values>
</item>
<item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
<initial-values>
<property name="text" value="CheckBox" />
</initial-values>
</item>
<item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
<initial-values>
<property name="text" value="Label" />
</initial-values>
</item>
<item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
<preferred-size width="150" height="-1" />
</default-constraints>
</item>
<item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
</item>
<item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
<preferred-size width="150" height="50" />
</default-constraints>
</item>
<item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
<preferred-size width="200" height="200" />
</default-constraints>
</item>
<item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
</item>
<item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
</item>
<item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
</item>
<item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
<preferred-size width="-1" height="20" />
</default-constraints>
</item>
<item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
<default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
</item>
<item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
<default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
</item>
</group>
</component>
</project>
\ No newline at end of file
.idea/vcs.xml 0 → 100644
View file @ f18f2469
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" />
</component>
</project>
\ No newline at end of file
README.md 0 → 100644
View file @ f18f2469
# Lab2 Veterinarian
build.gradle 0 → 100644
View file @ f18f2469
plugins {
id 'java'
}
group 'org.example'
version '1.0-SNAPSHOT'
repositories {
mavenCentral()
}
dependencies {
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.6.0'
testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine'
}
test {
useJUnitPlatform()
}
\ No newline at end of file
build/.DS_Store 0 → 100644
View file @ f18f2469
File added
build/tmp/compileJava/source-classes-mapping.txt 0 → 100644
View file @ f18f2469
chatRoom/KeyboardThread.java
chatRoom.KeyboardThread
chat/Client.java
chat.Client
chat/KeyboardThread.java
chat.KeyboardThread
chatRoom/Queue.java
chatRoom.Queue
chat/Queue.java
chat.Queue
chatRoom/ToOtherUserThread.java
chatRoom.ToOtherUserThread
chat/Server.java
chat.Server
chat/ToOtherUserThread.java
chat.ToOtherUserThread
chatRoom/MultiQueue.java
chatRoom.MultiQueue
chatRoom/MultiMessage.java
chatRoom.MultiMessage
chatRoom/MultiServer.java
chatRoom.MultiServer
chatRoom/MultiServerThreadFromClient.java
chatRoom.MultiServerThreadFromClient
chatRoom/MultiServerThreadToClients.java
chatRoom.MultiServerThreadToClients
chatRoom/Client.java
chatRoom.Client
gradle/wrapper/gradle-wrapper.properties 0 → 100644
View file @ f18f2469
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-6.7-bin.zip
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
gradlew 0 → 100755
View file @ f18f2469
#!/usr/bin/env sh
#
# Copyright 2015 the original author or authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
##############################################################################
##
## Gradle start up script for UN*X
##
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
PRG="$0"
# Need this for relative symlinks.
while [ -h "$PRG" ] ; do
ls=`ls -ld "$PRG"`
link=`expr "$ls" : '.*-> \(.*\)$'`
if expr "$link" : '/.*' > /dev/null; then
PRG="$link"
else
PRG=`dirname "$PRG"`"/$link"
fi
done
SAVED="`pwd`"
cd "`dirname \"$PRG\"`/" >/dev/null
APP_HOME="`pwd -P`"
cd "$SAVED" >/dev/null
APP_NAME="Gradle"
APP_BASE_NAME=`basename "$0"`
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD="maximum"
warn () {
echo "$*"
}
die () {
echo
echo "$*"
echo
exit 1
}
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "`uname`" in
CYGWIN* )
cygwin=true
;;
Darwin* )
darwin=true
;;
MINGW* )
msys=true
;;
NONSTOP* )
nonstop=true
;;
esac
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD="$JAVA_HOME/jre/sh/java"
else
JAVACMD="$JAVA_HOME/bin/java"
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD="java"
which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
# Increase the maximum file descriptors if we can.
if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
MAX_FD_LIMIT=`ulimit -H -n`
if [ $? -eq 0 ] ; then
if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
MAX_FD="$MAX_FD_LIMIT"
fi
ulimit -n $MAX_FD
if [ $? -ne 0 ] ; then
warn "Could not set maximum file descriptor limit: $MAX_FD"
fi
else
warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
fi
fi
# For Darwin, add options to specify how the application appears in the dock
if $darwin; then
GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
fi
# For Cygwin or MSYS, switch paths to Windows format before running java
if [ "$cygwin" = "true" -o "$msys" = "true" ] ; then
APP_HOME=`cygpath --path --mixed "$APP_HOME"`
CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
JAVACMD=`cygpath --unix "$JAVACMD"`
# We build the pattern for arguments to be converted via cygpath
ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
SEP=""
for dir in $ROOTDIRSRAW ; do
ROOTDIRS="$ROOTDIRS$SEP$dir"
SEP="|"
done
OURCYGPATTERN="(^($ROOTDIRS))"
# Add a user-defined pattern to the cygpath arguments
if [ "$GRADLE_CYGPATTERN" != "" ] ; then
OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
fi
# Now convert the arguments - kludge to limit ourselves to /bin/sh
i=0
for arg in "$@" ; do
CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option
if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition
eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
else
eval `echo args$i`="\"$arg\""
fi
i=`expr $i + 1`
done
case $i in
0) set -- ;;
1) set -- "$args0" ;;
2) set -- "$args0" "$args1" ;;
3) set -- "$args0" "$args1" "$args2" ;;
4) set -- "$args0" "$args1" "$args2" "$args3" ;;
5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
esac
fi
# Escape application args
save () {
for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
echo " "
}
APP_ARGS=`save "$@"`
# Collect all arguments for the java command, following the shell quoting and substitution rules
eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
exec "$JAVACMD" "$@"
gradlew.bat 0 → 100644
View file @ f18f2469
@rem
@rem Copyright 2015 the original author or authors.
@rem
@rem Licensed under the Apache License, Version 2.0 (the "License");
@rem you may not use this file except in compliance with the License.
@rem You may obtain a copy of the License at
@rem
@rem https://www.apache.org/licenses/LICENSE-2.0
@rem
@rem Unless required by applicable law or agreed to in writing, software
@rem distributed under the License is distributed on an "AS IS" BASIS,
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@rem See the License for the specific language governing permissions and
@rem limitations under the License.
@rem
@if "%DEBUG%" == "" @echo off
@rem ##########################################################################
@rem
@rem Gradle startup script for Windows
@rem
@rem ##########################################################################
@rem Set local scope for the variables with windows NT shell
if "%OS%"=="Windows_NT" setlocal
set DIRNAME=%~dp0
if "%DIRNAME%" == "" set DIRNAME=.
set APP_BASE_NAME=%~n0
set APP_HOME=%DIRNAME%
@rem Resolve any "." and ".." in APP_HOME to make it shorter.
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
@rem Find java.exe
if defined JAVA_HOME goto findJavaFromJavaHome
set JAVA_EXE=java.exe
%JAVA_EXE% -version >NUL 2>&1
if "%ERRORLEVEL%" == "0" goto execute
echo.
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
echo.
echo Please set the JAVA_HOME variable in your environment to match the
echo location of your Java installation.
goto fail
:findJavaFromJavaHome
set JAVA_HOME=%JAVA_HOME:"=%
set JAVA_EXE=%JAVA_HOME%/bin/java.exe
if exist "%JAVA_EXE%" goto execute
echo.
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
echo.
echo Please set the JAVA_HOME variable in your environment to match the
echo location of your Java installation.
goto fail
:execute
@rem Setup the command line
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
@rem Execute Gradle
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
:end
@rem End local scope for the variables with windows NT shell
if "%ERRORLEVEL%"=="0" goto mainEnd
:fail
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
rem the _cmd.exe /c_ return code!
if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
exit /b 1
:mainEnd
if "%OS%"=="Windows_NT" endlocal
:omega
settings.gradle 0 → 100644
View file @ f18f2469
rootProject.name = 'setup_SDP'
src/.DS_Store 0 → 100644
View file @ f18f2469
File added
src/main/java/chat/Client.java 0 → 100644
View file @ f18f2469
package chat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
class Client {
public static void main(String argv[]) throws Exception {
Queue q = new Queue();
// Thread that reads messages from stdin end queues them
KeyboardThread kt = new KeyboardThread(q);
kt.start();
Socket clientSocket = new Socket("localhost", 6789);
// Thread that reads messages from the queue and sends them to the server
ToOtherUserThread ous = new ToOtherUserThread(clientSocket, q);
ous.start();
BufferedReader inFromServer =
new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
while(true) {
System.out.println("FROM SERVER: " + inFromServer.readLine());
}
}
}
src/main/java/chat/KeyboardThread.java 0 → 100644
View file @ f18f2469
package chat;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
public class KeyboardThread extends Thread {
private Queue q;
public KeyboardThread(Queue q) {
this.q = q;
}
public void run() {
BufferedReader inFromUser =
new BufferedReader(new InputStreamReader(System.in));
while(true) {
try {
q.put(inFromUser.readLine());
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
src/main/java/chat/Queue.java 0 → 100644
View file @ f18f2469
package chat;
import java.util.ArrayList;
public class Queue {
public ArrayList<String> buffer = new ArrayList<String>();
public synchronized void put(String message) {
buffer.add(message);
notify();
}
public synchronized String take() {
String message = null;
while(buffer.size() == 0) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
if(buffer.size()>0){
message = buffer.get(0);
buffer.remove(0);
}
return message;
}
}
src/main/java/chat/Server.java 0 → 100644
View file @ f18f2469
package chat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String argv[]) throws Exception {
Queue q = new Queue();
// Thread that queues messages from the local user
KeyboardThread kt = new KeyboardThread(q);
kt.start();
ServerSocket welcomeSocket = new ServerSocket(6789);
Socket clientSocket = welcomeSocket.accept();
// Thread that consumes local messages and sends them to the other user
ToOtherUserThread ous = new ToOtherUserThread(clientSocket, q);
ous.start();
BufferedReader inFromClient =
new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
while(true) {
System.out.println("FROM CLIENT: " + inFromClient.readLine());
}
}
}
src/main/java/chat/ToOtherUserThread.java 0 → 100644
View file @ f18f2469
package chat;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
public class ToOtherUserThread extends Thread {
private Socket s;
private Queue q;
public ToOtherUserThread(Socket s, Queue q) {
this.s = s;
this.q = q;
}
public void run() {
DataOutputStream outToServer = null;
try {
outToServer = new DataOutputStream(s.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
}
String newMsg;
while(true) {
newMsg = q.take();
try {
outToServer.writeBytes(newMsg + '\n');
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
src/main/java/chatRoom/Client.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.io.*;
import java.net.*;
class Client {
public static void main(String argv[]) throws Exception {
Queue q = new Queue();
// Thread that reads messages from stdin end queues them
KeyboardThread kt = new KeyboardThread(q);
kt.start();
Socket clientSocket = new Socket("localhost", 6789);
// Thread that reads the message from a client and queues it to be forwarded to other clients
ToOtherUserThread ous = new ToOtherUserThread(clientSocket, q);
ous.start();
BufferedReader inFromServer =
new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
while(true) {
System.out.println(inFromServer.readLine());
}
}
}
src/main/java/chatRoom/KeyboardThread.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
public class KeyboardThread extends Thread {
private Queue q;
public KeyboardThread(Queue q) {
this.q = q;
}
public void run() {
BufferedReader inFromUser =
new BufferedReader(new InputStreamReader(System.in));
while(true) {
try {
q.put(inFromUser.readLine());
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
src/main/java/chatRoom/MultiMessage.java 0 → 100644
View file @ f18f2469
package chatRoom;
public class MultiMessage {
private String message;
private int clientId;
public MultiMessage(String message, int clientId) {
this.message = message;
this.clientId = clientId;
}
public String getMessage() {
return message;
}
public int getClientId() {
return clientId;
}
}
src/main/java/chatRoom/MultiQueue.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.util.ArrayList;
public class MultiQueue {
public ArrayList<MultiMessage> buffer = new ArrayList<MultiMessage>();
public synchronized void put(String message, int clientId) {
buffer.add(new MultiMessage(message, clientId));
notify();
}
public synchronized MultiMessage take() {
MultiMessage message = null;
while(buffer.size() == 0) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
if(buffer.size()>0){
message = buffer.get(0);
buffer.remove(0);
}
return message;
}
}
src/main/java/chatRoom/MultiServer.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
public class MultiServer {
public static void main(String argv[]) throws Exception {
MultiQueue q = new MultiQueue();
ArrayList<MultiServerThreadFromClient> tList = new ArrayList<MultiServerThreadFromClient>();
// Thread that consumes from the queue containing messages from the different clients
MultiServerThreadToClients mstc = new MultiServerThreadToClients(tList, q);
mstc.start();
ServerSocket welcomeSocket = new ServerSocket(6789);
Socket clientSocket;
MultiServerThreadFromClient msfc;
int idCounter = 0;
System.out.println("Ready to receive messages");
while(true) {
clientSocket = welcomeSocket.accept();
idCounter++;
// Thread that reads the message from a client and queues it to be forwarded to other clients
msfc = new MultiServerThreadFromClient(clientSocket, q, idCounter);
tList.add(msfc);
msfc.start();
}
}
}
src/main/java/chatRoom/MultiServerThreadFromClient.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class MultiServerThreadFromClient extends Thread {
private Socket s;
private MultiQueue q;
private DataOutputStream outToClient;
private BufferedReader inFromClient;
private int clientId;
public MultiServerThreadFromClient(Socket s, MultiQueue q, int clientId) throws IOException {
this.s = s;
this.q = q;
this.clientId = clientId;
this.outToClient = new DataOutputStream(s.getOutputStream());
this.inFromClient = new BufferedReader(new InputStreamReader(s.getInputStream()));
}
public void run() {
while(true) {
try {
String msg = inFromClient.readLine();
q.put(msg, clientId);
System.out.println(clientId+": "+msg);
} catch (IOException e) {
e.printStackTrace();
}
}
}
public void sendMsg(MultiMessage msg) throws IOException {
if(msg.getClientId() != clientId) {
outToClient.writeBytes(msg.getClientId()+": "+ msg.getMessage() + "\n");
}
}
}
src/main/java/chatRoom/MultiServerThreadToClients.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.io.IOException;
import java.util.ArrayList;
public class MultiServerThreadToClients extends Thread {
private ArrayList<MultiServerThreadFromClient> threads;
private MultiQueue q;
public MultiServerThreadToClients(ArrayList<MultiServerThreadFromClient> threads, MultiQueue q) {
this.threads = threads;
this.q = q;
}
public void run() {
MultiMessage newMsg;
while(true) {
newMsg = q.take();
for(MultiServerThreadFromClient t: threads) {
try {
t.sendMsg(newMsg);
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
src/main/java/chatRoom/Queue.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.util.ArrayList;
public class Queue {
public ArrayList<String> buffer = new ArrayList<String>();
public synchronized void put(String message) {
buffer.add(message);
notify();
}
public synchronized String take() {
String message = null;
while(buffer.size() == 0) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
if(buffer.size()>0){
message = buffer.get(0);
buffer.remove(0);
}
return message;
}
}
src/main/java/chatRoom/ToOtherUserThread.java 0 → 100644
View file @ f18f2469
package chatRoom;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
public class ToOtherUserThread extends Thread {
private Socket s;
private Queue q;
public ToOtherUserThread(Socket s, Queue q) {
this.s = s;
this.q = q;
}
public void run() {
DataOutputStream outToServer = null;
try {
outToServer = new DataOutputStream(s.getOutputStream());
} catch (IOException e) {
e.printStackTrace();
}
String newMsg;
while(true) {
newMsg = q.take();
try {
outToServer.writeBytes(newMsg + '\n');
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment