Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
D
DBE-DS-Group1-WS24
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Requirements
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Locked files
Build
Pipelines
Jobs
Pipeline schedules
Test cases
Artifacts
Deploy
Releases
Package registry
Container Registry
Model registry
Operate
Environments
Terraform modules
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Code review analytics
Issue analytics
Insights
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
Robin Leber
DBE-DS-Group1-WS24
Merge requests
!1
Dynamic Discovery, Client-Server
Code
Review changes
Check out branch
Download
Patches
Plain diff
Merged
Dynamic Discovery, Client-Server
Yong
into
main
Overview
0
Commits
1
Pipelines
0
Changes
2
Merged
Quoc Nguyen Dao
requested to merge
Yong
into
main
1 year ago
Overview
0
Commits
1
Pipelines
0
Changes
2
Expand
0
0
Merge request reports
Compare
main
main (base)
and
latest version
latest version
4ca12c6a
1 commit,
1 year ago
2 files
+
157
−
67
Inline
Compare changes
Side-by-side
Inline
Show whitespace changes
Show one file at a time
Files
2
Search (e.g. *.vue) (Ctrl+P)
client.py
+
84
−
27
Options
import
socket
import
threading
from
datetime
import
datetime
def
receive_messages
():
while
True
:
try
:
# Empfange Nachricht vom Server
data
=
client_socket
.
recv
(
1024
)
print
(
data
.
decode
(
'
utf-8
'
))
except
:
break
# Client-Konfiguration
host
=
'
127.0.0.1
'
port
=
5555
# Verbinde zum Server
client_socket
=
socket
.
socket
(
socket
.
AF_INET
,
socket
.
SOCK_STREAM
)
client_socket
.
connect
((
host
,
port
))
print
(
f
'
Du bist jetzt im Chat
'
)
# Starte einen Thread, um Nachrichten vom Server zu empfangen
receive_thread
=
threading
.
Thread
(
target
=
receive_messages
)
receive_thread
.
start
()
# Haupt-Thread zum Senden von Nachrichten
while
True
:
message
=
input
()
client_socket
.
send
(
message
.
encode
(
'
utf-8
'
))
# Broadcast address and port
BROADCAST_IP
=
"
192.168.0.255
"
BROADCAST_PORT
=
5973
# Local host information
MY_HOST
=
socket
.
gethostname
()
MY_IP
=
socket
.
gethostbyname
(
MY_HOST
)
class
Client
():
def
__init__
(
self
):
self
.
currentLeader
=
''
self
.
server_socket
=
None
# print the current date and time
def
printwt
(
self
,
msg
):
current_date_time
=
datetime
.
now
().
strftime
(
'
%Y-%m-%d %H:%M:%S
'
)
print
(
f
'
[
{
current_date_time
}
]
{
msg
}
'
)
# dynamic discoverey: client sends request to server group and gets the IP of server as reply
def
BroadcastSendAndReceive
(
self
):
message
=
'
New client wants to connect:
'
+
MY_IP
# Create a UDP socket
broadcast_socket
=
socket
.
socket
(
socket
.
AF_INET
,
socket
.
SOCK_DGRAM
)
# Send message on broadcast address
broadcast_socket
.
sendto
(
str
.
encode
(
message
),
(
BROADCAST_IP
,
BROADCAST_PORT
))
# Send broadcast message
self
.
printwt
(
"
Sent my IP to server group
"
)
while
True
:
try
:
# receive reply data (server IP) from the other participants
reply
,
addr
=
broadcast_socket
.
recvfrom
(
1024
)
if
reply
:
# decode received data
reply_addr
=
reply
.
decode
()
self
.
currentLeader
=
reply_addr
self
.
printwt
(
f
'
Got Leader address:
{
self
.
currentLeader
}
'
)
# Connect to the server using TCP
self
.
server_socket
=
socket
.
socket
(
socket
.
AF_INET
,
socket
.
SOCK_STREAM
)
self
.
server_socket
.
connect
((
self
.
currentLeader
,
5555
))
print
(
"
You have entered the chat room
"
)
# Starte einen Thread, um Nachrichten zu empfangen
receive_thread
=
threading
.
Thread
(
target
=
self
.
receive_messages
)
receive_thread
.
start
()
# Haupt-Thread zum Senden von Nachrichten
while
True
:
message
=
input
()
timestamped_message
=
f
'
[
{
datetime
.
now
().
strftime
(
"
%Y-%m-%d %H
:
%
M
:
%
S
"
)
}
]
{
message
}
'
self
.
server_socket
.
send
(
timestamped_message
.
encode
(
'
utf-8
'
))
except
socket
.
timeout
:
pass
def
receive_messages
(
self
):
while
True
:
try
:
data
=
self
.
server_socket
.
recv
(
1024
)
if
not
data
:
break
print
(
data
.
decode
(
'
utf-8
'
))
except
:
break
# starting all simultaneously working procedures
if
__name__
==
"
__main__
"
:
client
=
Client
()
thread1
=
threading
.
Thread
(
target
=
client
.
BroadcastSendAndReceive
)
thread1
.
start
()
thread1
.
join
()
\ No newline at end of file
Loading