|
@@ -39,59 +39,12 @@ class ChatConsumer(
|
39
|
39
|
Mixins.DevMroMixin,
|
40
|
40
|
AsyncWebsocketConsumer,
|
41
|
41
|
):
|
42
|
|
- # def connect(self):
|
43
|
42
|
async def ws_conn0(self):
|
44
|
|
-
|
45
|
|
- # print("ChatConsumer:ws_conn0")
|
46
|
|
- # p("!!!!!!!!!!!!!!!!!!!!?")
|
47
|
43
|
print("",end="",flush=True)
|
48
|
|
- # time.sleep(1.5)
|
49
|
|
-
|
50
|
|
- # p("!!!!!!!!!!!!!!!!!!!!")
|
51
|
|
- r'''
|
52
|
|
- await self.send(text_data=json.dumps({
|
53
|
|
- 'wsconn': {"abc.":12}
|
54
|
|
- }))
|
55
|
|
- '''
|
56
|
|
-
|
57
|
|
- # print("",end="",flush=True)
|
58
|
44
|
self.accept()
|
59
|
|
-
|
60
|
|
- r'''
|
61
|
|
- await self.send(text_data=json.dumps({
|
62
|
|
- 'wsconn': {"abc.":123}
|
63
|
|
- }))
|
64
|
|
- '''
|
65
|
|
-
|
66
|
|
-
|
67
|
45
|
async def ws_disconn(self, close_code):
|
68
|
46
|
pass
|
69
|
47
|
|
70
|
|
- async def ws_disconn_z(self, close_code):
|
71
|
|
- pass
|
72
|
48
|
|
73
|
|
- async def ws_rec(self, text_data):
|
74
|
|
- return
|
75
|
|
- p("text_data:",text_data)
|
76
|
|
- print("",end="",flush=True)
|
77
|
|
- text_data_json = json.loads(text_data)
|
78
|
|
- message = text_data_json['message']
|
79
|
|
-
|
80
|
|
- await self.send(text_data=json.dumps({
|
81
|
|
- 'message': message
|
82
|
|
- }))
|
83
|
|
-
|
84
|
|
-
|
85
|
|
- await self.send(text_data=json.dumps({
|
86
|
|
- 'zzz': {"abc":123}
|
87
|
|
- }))
|
88
|
|
-
|
89
|
|
-
|
90
|
|
-# print(">>>>>>>>>>>>>")
|
91
|
49
|
Mixins.ChatConsumer = ChatConsumer
|
92
|
50
|
|
93
|
|
-print("++?",end="\n",flush=True)
|
94
|
|
-# print("++2?",end="\n",flush=True)
|
95
|
|
-
|
96
|
|
-# print("++",end="\n",flush=True)
|
97
|
|
-
|