FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
JavaExercises/Head First Java/MusicServer.java at master · biblelamp/JavaExercises · GitHub
biblelamp
/
JavaExercises
Public
Notifications
You must be signed in to change notification settings
Fork
130
Star
153
Code
Issues
1
Pull requests
9
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
JavaExercises
/
Head First Java
/
MusicServer.java
Copy path
More file actions
More file actions
Latest commit
History
History
History
71 lines (54 loc) · 1.9 KB
Breadcrumbs
JavaExercises
/
Head First Java
/
MusicServer.java
Copy path
File metadata and controls
71 lines (54 loc) · 1.9 KB
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
import
java
.
io
.*;
import
java
.
net
.*;
import
java
.
util
.*;
public
class
MusicServer
{
ArrayList
clientOutputStreams
;
public
static
void
main
(
String
[]
args
) {
new
MusicServer
().
go
();
}
public
class
ClientHandler
implements
Runnable
{
ObjectInputStream
in
;
Socket
sock
;
public
ClientHandler
(
Socket
clientSOcket
) {
try
{
sock
=
clientSOcket
;
in
=
new
ObjectInputStream
(
sock
.
getInputStream
());
}
catch
(
Exception
ex
) {
ex
.
printStackTrace
(); }
}
public
void
run
() {
Object
o1
;
Object
o2
;
try
{
while
((
o1
=
in
.
readObject
()) !=
null
) {
o2
=
in
.
readObject
();
System
.
out
.
println
(
"Read two objects"
);
tellEveryone
(
o1
,
o2
);
}
}
catch
(
Exception
ex
) {
ex
.
printStackTrace
(); }
}
}
public
void
go
() {
clientOutputStreams
=
new
ArrayList
();
try
{
ServerSocket
serverSock
=
new
ServerSocket
(
4242
);
while
(
true
) {
Socket
clientSocket
=
serverSock
.
accept
();
ObjectOutputStream
out
=
new
ObjectOutputStream
(
clientSocket
.
getOutputStream
());
clientOutputStreams
.
add
(
out
);
Thread
t
=
new
Thread
(
new
ClientHandler
(
clientSocket
));
t
.
start
();
System
.
out
.
println
(
"Got a connection"
);
}
}
catch
(
Exception
ex
) {
ex
.
printStackTrace
(); }
}
public
void
tellEveryone
(
Object
one
,
Object
two
) {
Iterator
it
=
clientOutputStreams
.
iterator
();
while
(
it
.
hasNext
()) {
try
{
ObjectOutputStream
out
= (
ObjectOutputStream
)
it
.
next
();
out
.
writeObject
(
one
);
out
.
writeObject
(
two
);
}
catch
(
Exception
ex
) {
ex
.
printStackTrace
(); }
}
}
}
Back
|
FazBrowse Home
|
New Git URL