1. 项目背景与目标
作为一个Android开发者，我一直想通过一个完整的项目来系统性地学习Android开发的各项核心技能。微信作为国内最流行的社交应用，其功能模块涵盖了Android开发的绝大多数核心技术点，因此我决定以开发一个简易版微信作为学习项目。
这个系列的第二部分，我们将重点实现微信的核心聊天功能。相比第一部分的基础框架搭建，这部分会涉及更多Android开发的进阶知识，包括：
- 网络通信与消息推送
- 本地数据库存储
- 复杂UI交互
- 多媒体处理
提示：本教程假设你已经完成了Android开发环境的搭建，并具备基本的Kotlin/Java编程能力。如果还没有准备好，建议先完成Android Studio的安装和基础配置。
2. 开发环境准备
2.1 工具与依赖项
我们需要确保开发环境包含以下组件：
- Android Studio最新稳定版（建议2023.3.1或更高）
- Android SDK 34（API Level 34）
- Kotlin 1.9.0
- Gradle 8.0
在项目的build.gradle文件中添加以下关键依赖：
dependencies { // 网络通信 implementation 'com.squareup.retrofit2:retrofit:2.9.0' implementation 'com.squareup.okhttp3:okhttp:4.11.0' // 数据库 implementation 'androidx.room:room-runtime:2.5.2' kapt 'androidx.room:room-compiler:2.5.2' // UI组件 implementation 'androidx.recyclerview:recyclerview:1.3.1' implementation 'com.github.bumptech.glide:glide:4.15.1' // 消息推送 implementation 'com.google.firebase:firebase-messaging:23.2.1' }2.2 项目结构设计
采用MVVM架构模式，主要包结构如下：
com.example.wechat ├── model # 数据模型 ├── repository # 数据仓库 ├── viewmodel # ViewModel ├── ui # 界面相关 │ ├── chat # 聊天相关界面 │ └── contacts # 联系人界面 ├── network # 网络通信 └── database # 本地存储3. 核心功能实现
3.1 聊天界面布局
聊天界面的核心是RecyclerView，我们需要创建两种不同的item布局：发送消息和接收消息。
<!-- item_chat_send.xml --> <LinearLayout android:layout_width="match_parent" android:layout_height="wrap_content" android:orientation="horizontal" android:gravity="end"> <TextView android:id="@+id/tv_message" android:background="@drawable/bg_chat_send" android:layout_width="wrap_content" android:layout_height="wrap_content" android:maxWidth="240dp" android:padding="12dp" android:textColor="@color/white"/> </LinearLayout> <!-- item_chat_receive.xml --> <LinearLayout android:layout_width="match_parent" android:layout_height="wrap_content" android:orientation="horizontal" android:gravity="start"> <ImageView android:id="@+id/iv_avatar" android:layout_width="40dp" android:layout_height="40dp"/> <TextView android:id="@+id/tv_message" android:background="@drawable/bg_chat_receive" android:layout_width="wrap_content" android:layout_height="wrap_content" android:maxWidth="240dp" android:padding="12dp"/> </LinearLayout>3.2 消息数据模型
定义消息实体类，使用Room注解标记为数据库表：
@Entity(tableName = "messages") data class ChatMessage( @PrimaryKey(autoGenerate = true) val id: Long = 0, @ColumnInfo(name = "sender_id") val senderId: String, @ColumnInfo(name = "receiver_id") val receiverId: String, @ColumnInfo(name = "content") val content: String, @ColumnInfo(name = "timestamp") val timestamp: Long, @ColumnInfo(name = "type") val type: Int, // 0=文本,1=图片,2=语音 @ColumnInfo(name = "status") val status: Int // 0=发送中,1=已发送,2=已读 )3.3 消息发送与接收
实现消息发送功能，包括网络请求和本地存储：
class ChatRepository( private val messageDao: MessageDao, private val apiService: ChatApiService ) { suspend fun sendMessage(message: ChatMessage): Result<Unit> { return try { // 先保存到本地数据库 messageDao.insertMessage(message.copy(status = 0)) // 发送到服务器 val response = apiService.sendMessage(message) if (response.isSuccessful) { // 更新消息状态 messageDao.updateMessageStatus(message.id, 1) Result.success(Unit) } else { // 标记发送失败 messageDao.updateMessageStatus(message.id, 3) Result.failure(Exception("Send failed")) } } catch (e: Exception) { messageDao.updateMessageStatus(message.id, 3) Result.failure(e) } } fun observeMessages(chatId: String): Flow<List<ChatMessage>> { return messageDao.getMessagesByChat(chatId) } }3.4 消息推送集成
使用Firebase Cloud Messaging实现消息推送：
class MyFirebaseMessagingService : FirebaseMessagingService() { override fun onMessageReceived(remoteMessage: RemoteMessage) { remoteMessage.data.let { data -> val message = ChatMessage( senderId = data["senderId"] ?: "", receiverId = data["receiverId"] ?: "", content = data["content"] ?: "", timestamp = System.currentTimeMillis(), type = data["type"]?.toInt() ?: 0, status = 1 ) // 保存到本地数据库 CoroutineScope(Dispatchers.IO).launch { MessageDatabase.getDatabase(this@MyFirebaseMessagingService) .messageDao() .insertMessage(message) // 发送广播通知UI更新 sendBroadcast(Intent("NEW_MESSAGE_RECEIVED").apply { putExtra("message", message) }) } } } }4. 高级功能实现
4.1 语音消息录制与播放
实现语音消息功能需要处理音频录制和播放：
class AudioRecorder(private val context: Context) { private var mediaRecorder: MediaRecorder? = null private var outputFile: File? = null fun startRecording(): File { outputFile = File(context.cacheDir, "voice_${System.currentTimeMillis()}.3gp") mediaRecorder = MediaRecorder().apply { setAudioSource(MediaRecorder.AudioSource.MIC) setOutputFormat(MediaRecorder.OutputFormat.THREE_GPP) setAudioEncoder(MediaRecorder.AudioEncoder.AMR_NB) setOutputFile(outputFile?.absolutePath) prepare() start() } return outputFile!! } fun stopRecording(): Long { mediaRecorder?.apply { stop() release() } mediaRecorder = null return outputFile?.length() ?: 0 } } class AudioPlayer { private var mediaPlayer: MediaPlayer? = null fun playAudio(file: File, onCompletion: () -> Unit) { mediaPlayer?.release() mediaPlayer = MediaPlayer().apply { setDataSource(file.absolutePath) prepare() setOnCompletionListener { onCompletion() release() } start() } } fun stopPlaying() { mediaPlayer?.release() mediaPlayer = null } }4.2 图片消息处理
使用Glide加载图片消息，并实现图片选择功能：
// 在Adapter中加载图片消息 Glide.with(itemView.context) .load(message.content) // content存储的是图片URL或本地路径 .override(600) // 限制最大宽度 .into(imageView) // 选择图片 private fun selectImage() { val intent = Intent(Intent.ACTION_GET_CONTENT).apply { type = "image/*" putExtra(Intent.EXTRA_ALLOW_MULTIPLE, true) } startActivityForResult(intent, REQUEST_IMAGE_PICK) } override fun onActivityResult(requestCode: Int, resultCode: Int, data: Intent?) { if (requestCode == REQUEST_IMAGE_PICK && resultCode == RESULT_OK) { data?.data?.let { uri -> // 压缩并上传图片 val file = compressImage(uri) uploadImage(file) } } } private fun compressImage(uri: Uri): File { // 实现图片压缩逻辑 // ... }5. 性能优化与调试
5.1 消息列表优化
聊天界面通常会有大量消息，需要优化RecyclerView性能：
// 使用DiffUtil高效更新列表 class MessageDiffCallback( private val oldList: List<ChatMessage>, private val newList: List<ChatMessage> ) : DiffUtil.Callback() { override fun getOldListSize() = oldList.size override fun getNewListSize() = newList.size override fun areItemsTheSame(oldPos: Int, newPos: Int) = oldList[oldPos].id == newList[newPos].id override fun areContentsTheSame(oldPos: Int, newPos: Int) = oldList[oldPos] == newList[newPos] } // 在Adapter中应用DiffUtil fun submitList(newList: List<ChatMessage>) { val diffResult = DiffUtil.calculateDiff(MessageDiffCallback(currentList, newList)) currentList = newList diffResult.dispatchUpdatesTo(this) }5.2 数据库查询优化
对于大量消息数据，需要优化数据库查询：
@Dao interface MessageDao { @Query("SELECT * FROM messages WHERE (sender_id = :userId AND receiver_id = :chatId) OR (sender_id = :chatId AND receiver_id = :userId) ORDER BY timestamp DESC LIMIT :limit OFFSET :offset") fun getMessagesPaginated(userId: String, chatId: String, limit: Int, offset: Int): List<ChatMessage> @Query("SELECT * FROM messages WHERE chat_id = :chatId ORDER BY timestamp DESC") fun getMessagesByChat(chatId: String): Flow<List<ChatMessage>> @Query("UPDATE messages SET status = :status WHERE id = :messageId") suspend fun updateMessageStatus(messageId: Long, status: Int) }5.3 常见问题排查
在开发过程中，我遇到了几个典型问题及解决方案：
- 消息重复显示：
- 原因：观察数据库的Flow在数据更新时会重新发射整个列表
- 解决：在Repository层对列表进行去重处理
fun observeMessages(chatId: String): Flow<List<ChatMessage>> { return messageDao.getMessagesByChat(chatId) .distinctUntilChanged { old, new -> old.size == new.size && old.lastOrNull()?.id == new.lastOrNull()?.id } }- 语音消息播放冲突：
- 现象：快速点击多条语音消息会导致同时播放
- 解决：实现单一播放器实例，播放新消息前停止当前播放
class AudioPlayerManager { private var currentPlayer: AudioPlayer? = null fun play(file: File, onCompletion: () -> Unit) { currentPlayer?.stopPlaying() currentPlayer = AudioPlayer().apply { playAudio(file) { onCompletion() currentPlayer = null } } } }- 图片加载内存溢出：
- 现象：加载大量图片时出现OOM
- 解决：配置Glide的内存缓存策略
Glide.with(this) .load(url) .override(Target.SIZE_ORIGINAL) .diskCacheStrategy(DiskCacheStrategy.ALL) .downsample(DownsampleStrategy.CENTER_INSIDE) .into(imageView)6. 项目扩展与进阶
完成基础聊天功能后，可以考虑进一步扩展：
6.1 实现消息撤回功能
// 在Repository中添加撤回方法 suspend fun recallMessage(messageId: Long): Boolean { return try { val response = apiService.recallMessage(messageId) if (response.isSuccessful) { messageDao.deleteMessage(messageId) true } else { false } } catch (e: Exception) { false } } // 在ViewModel中处理撤回 fun recallMessage(messageId: Long) { viewModelScope.launch { val success = repository.recallMessage(messageId) if (!success) { _errorEvent.emit("撤回失败，请重试") } } }6.2 添加消息已读回执
// 扩展消息状态 const val STATUS_SENDING = 0 const val STATUS_SENT = 1 const val STATUS_DELIVERED = 2 const val STATUS_READ = 3 // 实现已读标记 fun markMessagesAsRead(chatId: String) { viewModelScope.launch { val unreadMessages = repository.getUnreadMessages(chatId) unreadMessages.forEach { message -> repository.updateMessageStatus(message.id, STATUS_READ) apiService.markAsRead(message.id) } } }6.3 支持消息搜索
@Query("SELECT * FROM messages WHERE content LIKE :query AND (sender_id = :userId OR receiver_id = :userId) ORDER BY timestamp DESC") fun searchMessages(userId: String, query: String): Flow<List<ChatMessage>> // 在ViewModel中暴露搜索方法 fun searchMessages(query: String): Flow<List<ChatMessage>> { return repository.searchMessages(currentUserId, "%$query%") }在实现这个简易版微信的过程中，我深刻体会到实际项目开发与教程示例的差异。最大的挑战不在于单个功能的实现，而在于各种功能模块之间的协调和数据一致性维护。比如当同时有网络推送、本地操作和用户交互时，如何保证消息状态的正确同步就需要仔细设计。
一个实用的建议是：在开发这类实时通信应用时，一定要先设计好数据流和状态管理方案。我最初没有考虑周全，导致后来不得不重构部分代码来修复状态同步问题。采用单向数据流模式（如MVI）可能会是更好的选择，特别是在复杂的交互场景中。
![[C++]内存管理：串顺序存储的内存回收](http://pic.xiahunao.cn/yaotu/[C++]内存管理：串顺序存储的内存回收)
