Skip to content
GitLab
Menu
Projects
Groups
Snippets
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Sign in
Toggle navigation
Menu
Open sidebar
soldier.mh.2001
project-team-28
Commits
4a3feb6c
Commit
4a3feb6c
authored
Jul 21, 2021
by
soldier.mh.2001
Browse files
ye chizi hast
parent
73663b8d
Changes
1
Hide whitespace changes
Inline
Side-by-side
server/src/main/java/org/serverController/ChatBoxController.java
View file @
4a3feb6c
...
...
@@ -31,7 +31,7 @@ public class ChatBoxController {
while
(
true
)
{
Socket
socket
=
chatServerSocket
.
accept
();
objectOutputStream
=
new
ObjectOutputStream
(
socket
.
getOutputStream
());
objectOutputStream
.
reset
();
//
objectOutputStream.reset();
System
.
out
.
println
(
"sth"
);
chatBoxSockets
.
add
(
socket
);
// startRefreshThread(socket);
...
...
@@ -44,41 +44,42 @@ public class ChatBoxController {
}
}
public
void
startRefreshThread
(
Socket
socket
)
{
new
Thread
(()
->
{
try
{
ObjectOutputStream
objectOutputStream
=
new
ObjectOutputStream
(
socket
.
getOutputStream
());
while
(
true
)
{
objectOutputStream
.
reset
();
objectOutputStream
.
writeObject
(
MainServer
.
getMessages
());
System
.
out
.
println
(
"ferestaadam bemola"
);
objectOutputStream
.
flush
();
}
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}).
start
();
}
//
public void startRefreshThread(Socket socket) {
//
//
new Thread(() -> {
//
try {
//
ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
//
while (true) {
//
objectOutputStream.reset();
//
objectOutputStream.writeObject(MainServer.getMessages());
//
System.out.println("ferestaadam bemola");
//
objectOutputStream.flush();
//
}
//
//
//
} catch (Exception e) {
//
e.printStackTrace();
//
}
//
//
}).start();
//
//
}
public
static
void
addMessage
(
String
message
)
{
MainServer
.
getMessages
().
add
(
message
);
System
.
out
.
println
(
message
);
}
public
void
refresh
(){
public
static
void
refresh
(){
for
(
Socket
socket
:
chatBoxSockets
){
try
{
objectOutputStream
=
new
ObjectOutputStream
(
socket
.
getOutputStream
());
ObjectOutputStream
objectOutputStream
=
new
ObjectOutputStream
(
socket
.
getOutputStream
());
objectOutputStream
.
reset
();
objectOutputStream
.
writeObject
(
MainServer
.
getMessages
());
objectOutputStream
.
flush
();
objectOutputStream
.
close
();
}
catch
(
IO
Exception
e
)
{
//
objectOutputStream.close();
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
}
...
...
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment