实际使用中遇到的问题的一些修改，经过测试。

src/Wechaty/Wechaty.cs

@@ -475,29 +475,71 @@ public ContactSelf UserSelf()
             throw new NotImplementedException();
         }
 
-        public Task<Message> Say(string text, params Contact[]? replyTo)
+        public async Task<Message?> Say(string text, params Contact[]? replyTo)
         {
-            throw new NotImplementedException();
+            var msgId = await Puppet.MessageSendText(Id, text, replyTo?.Select(c => c.Id));
+            if (msgId != null)
+            {
+                var result = WechatyInstance.Message.Load(msgId);
+                await result.Ready;
+                return result;
+            }
+            return null;
         }
-
-        public Task<Message> Say(Contact contact, params Contact[]? replyTo)
+        public async Task<Message?> Say(Message message)
         {
-            throw new NotImplementedException();
+            var msgId = await Puppet.MessageForward(Id, message.Id);
+            if (msgId != null)
+            {
+                var result = WechatyInstance.Message.Load(msgId);
+                await result.Ready;
+                return result;
+            }
+            return null;
         }
-
-        public Task<Message> Say(FileBox fileBox, params Contact[]? replyTo)
+        public async Task<Message?> Say(string id, Contact contact)
         {
-            throw new NotImplementedException();
+            var msgId = await Puppet.MessageSendContact(id, contact.Id);
+            if (msgId != null)
+            {
+                var result = WechatyInstance.Message.Load(msgId);
+                await result.Ready;
+                return result;
+            }
+            return null;
         }
-
-        public Task<Message> Say(MiniProgram miniProgram, params Contact[]? replyTo)
+        public async Task<Message?> Say(string id,FileBox fileBox)
         {
-            throw new NotImplementedException();
+            var msgId = await Puppet.MessageSendFile(id, fileBox);
+            if (msgId != null)
+            {
+                var result = WechatyInstance.Message.Load(msgId);
+                await result.Ready;
+                return result;
+            }
+            return null;
         }
-
-        public Task<Message> Say(UrlLink urlLink, params Contact[]? replyTo)
+        public async Task<Message?> Say(string id,UrlLink urlLink)
         {
-            throw new NotImplementedException();
+            var msgId = await Puppet.MessageSendUrl(id, urlLink.Payload);
+            if (msgId != null)
+            {
+                var result = WechatyInstance.Message.Load(msgId);
+                await result.Ready;
+                return result;
+            }
+            return null;
+        }
+        public async Task<Message?> Say(string id, MiniProgram miniProgram)
+        {
+            var msgId = await Puppet.MessageSendMiniProgram(id, miniProgram.Payload);
+            if (msgId != null)
+            {
+                var result = WechatyInstance.Message.Load(msgId);
+                await result.Ready;
+                return result;
+            }
+            return null;
         }
 
         public void Ding()

src/modules/Wechaty.Module.Puppet/WechatyPuppet.cs

@@ -2,6 +2,7 @@
 using System.Collections.Generic;
 using System.Collections.Immutable;
 using System.Linq;
+using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.CodeAnalysis;
 using Microsoft.Extensions.Logging;
@@ -611,6 +612,7 @@ public async Task SetFriendshipPayload(string friendshipId, FriendshipPayload ne
         public abstract Task<string> MessageContact(string messageId);
         public abstract Task<FileBox> MessageFile(string messageId);
         public abstract Task<FileBox> MessageImage(string messageId, ImageType imageType);
+        public abstract Task<byte[]> MessageImageStream(string messageId, ImageType imageType, CancellationToken cancellationToken);
         public abstract Task<MiniProgramPayload> MessageMiniProgram(string messageId);
         public abstract Task<UrlLinkPayload> MessageUrl(string messageId);
 

src/modules/Wechaty.Module.PuppetService/GrpcPuppet.Message.cs

@@ -1,4 +1,5 @@
 using System.Collections.Generic;
+using System.Threading;
 using System.Threading.Tasks;
 using github.wechaty.grpc.puppet;
 using Newtonsoft.Json;
@@ -47,6 +48,24 @@ public override async Task<FileBox> MessageImage(string messageId, Puppet.Schema
             return FileBox.FromJson(fileBox);
         }
 
+        public override async Task<byte[]> MessageImageStream(string messageId, Puppet.Schemas.ImageType imageType, CancellationToken cancellationToken = default)
+        {
+            var request = new MessageImageStreamRequest
+            {
+                Id = messageId,
+                Type = (github.wechaty.grpc.puppet.ImageType)imageType
+            };
+
+            var response = grpcClient.MessageImageStream(request);
+            var bytes = new List<byte>();
+            while (await response.ResponseStream.MoveNext(cancellationToken))
+            {
+                bytes.AddRange(response.ResponseStream.Current.FileBoxChunk.Data.ToByteArray());
+            }
+
+            return bytes.ToArray();
+        }
+
         public override async Task<MiniProgramPayload> MessageMiniProgram(string messageId)
         {
             var request = new MessageMiniProgramRequest