質問編集履歴
1
修正済みのコードを記載しました。
title
CHANGED
|
File without changes
|
body
CHANGED
|
@@ -169,4 +169,49 @@
|
|
|
169
169
|
start_server = websockets.serve(server, address, port)
|
|
170
170
|
asyncio.get_event_loop().run_until_complete(start_server)
|
|
171
171
|
asyncio.get_event_loop().run_forever()
|
|
172
|
+
```
|
|
173
|
+
|
|
174
|
+
|
|
175
|
+
|
|
176
|
+
### ＊追記(ご指摘頂いたように修正)
|
|
177
|
+
```python
|
|
178
|
+
import asyncio
|
|
179
|
+
import websockets
|
|
180
|
+
import json
|
|
181
|
+
|
|
182
|
+
|
|
183
|
+
address = "localhost"
|
|
184
|
+
port = 8888
|
|
185
|
+
|
|
186
|
+
Users = []
|
|
187
|
+
|
|
188
|
+
# 受信コールバック
|
|
189
|
+
async def server(websocket, path):
|
|
190
|
+
print(websocket)
|
|
191
|
+
print('connect.')
|
|
192
|
+
Users.append(websocket)
|
|
193
|
+
while(True):
|
|
194
|
+
# 受信
|
|
195
|
+
|
|
196
|
+
received_packet = await websocket.recv()
|
|
197
|
+
# dictionary = json.loads(received_packet)
|
|
198
|
+
print(type(received_packet))
|
|
199
|
+
print("{}: {}".format(path, received_packet))
|
|
200
|
+
# 送信
|
|
201
|
+
# dictionary['message'] = "Hi! Mr:{}.".format(dictionary['username'])
|
|
202
|
+
# dictionary['bool'] = False
|
|
203
|
+
# packet = json.dumps(dictionary).encode()
|
|
204
|
+
print('send')
|
|
205
|
+
packet = 'Hi! I received :{}'.format(received_packet)
|
|
206
|
+
for user in Users:
|
|
207
|
+
await user.send(packet)
|
|
208
|
+
|
|
209
|
+
# print(vars(websocket))
|
|
210
|
+
|
|
211
|
+
|
|
212
|
+
|
|
213
|
+
|
|
214
|
+
start_server = websockets.serve(server, address, port)
|
|
215
|
+
asyncio.get_event_loop().run_until_complete(start_server)
|
|
216
|
+
asyncio.get_event_loop().run_forever()
|
|
172
217
|
```
|