diff --git a/__pycache__/settings.cpython-39.pyc b/__pycache__/settings.cpython-39.pyc
new file mode 100644
index 0000000..e936db7
Binary files /dev/null and b/__pycache__/settings.cpython-39.pyc differ
diff --git a/app.py b/app.py
index 8bfaaf8..b3a0c08 100644
--- a/app.py
+++ b/app.py
@@ -13,7 +13,8 @@ def shop_random():
     return shop
 
 def send_queue(data={}):
-    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost, settings.MQPort))
+    credentials = pika.PlainCredentials('newrain', '123456')
+    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost, settings.MQPort, credentials=credentials))
     channel = connection.channel()
 
     # 声明一个名为 'message_queue' 的队列
@@ -28,18 +29,21 @@ def send_queue(data={}):
 
 def read_queue():
     # 建立与RabbitMQ服务器的连接
-    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost, settings.MQPort))
+    credentials = pika.PlainCredentials('newrain', '123456')
+    connection = pika.BlockingConnection(
+        pika.ConnectionParameters(host=settings.MQHost, port=settings.MQPort, credentials=credentials)
+    )
     channel = connection.channel()
 
     # 声明一个队列
-    channel.queue_declare(queue=settings.MQName)
+    queue_info = channel.queue_declare(queue=settings.MQName, passive=True)
 
     # 获取队列中的消息数量
-    queue_info = channel.queue_declare(queue=settings.MQName, passive=True)
     message_count = queue_info.method.message_count
     connection.close()
     return message_count
 
+
 @app.route('/', methods=["GET", "POST"])
 def index():
     if request.method == 'POST':
@@ -55,10 +59,12 @@ def index():
 
 @app.route('/read', methods=["GET","POST"])
 def read():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(settings.MQHost,settings.MQPort))
-    channel = connection.channel()
-
+    credentials = pika.PlainCredentials('newrain', '123456')
+    connection = pika.BlockingConnection(
+        pika.ConnectionParameters(host=settings.MQHost, port=settings.MQPort, credentials=credentials)
+    )
     # 声明一个名为 'message_queue' 的队列
+    channel = connection.channel()
     channel.queue_declare(queue=settings.MQName)
     data = []
 
diff --git a/settings.py b/settings.py
index 314d93e..537b800 100644
--- a/settings.py
+++ b/settings.py
@@ -1,11 +1,11 @@
 # rabbitmq 配置
 MQName="message_queue"
-MQUser="guest"
-MQPassword="guest"
-MQHost="localhost"
+MQUser="newrain"
+MQPassword="123456"
+MQHost="11.0.1.153"
 MQPort=5672
 
 # mysql数据库配置
 DBHost="localhost"
 DBUser="root"
-DBPassword="QianFeng@123"
\ No newline at end of file
+DBPassword="123456"