聊天应用Youtube教程_Java_下载.zip

package com.mianasad.chatsapp.Activities; import androidx.annotation.NonNull; import androidx.annotation.Nullable; import androidx.appcompat.app.AppCompatActivity; import androidx.recyclerview.widget.LinearLayoutManager; import android.app.ProgressDialog; import android.content.Intent; import android.net.Uri; import android.os.Bundle; import android.os.Handler; import android.text.Editable; import android.text.TextWatcher; import android.util.Log; import android.view.KeyEvent; import android.view.Menu; import android.view.View; import android.widget.Toast; import com.android.volley.AuthFailureError; import com.android.volley.Request; import com.android.volley.RequestQueue; import com.android.volley.Response; import com.android.volley.VolleyError; import com.android.volley.toolbox.JsonObjectRequest; import com.android.volley.toolbox.Volley; import com.bumptech.glide.Glide; import com.google.android.gms.tasks.OnCompleteListener; import com.google.android.gms.tasks.OnSuccessListener; import com.google.android.gms.tasks.Task; import com.google.firebase.auth.FirebaseAuth; import com.google.firebase.database.DataSnapshot; import com.google.firebase.database.DatabaseError; import com.google.firebase.database.DatabaseReference; import com.google.firebase.database.FirebaseDatabase; import com.google.firebase.database.ValueEventListener; import com.google.firebase.storage.FirebaseStorage; import com.google.firebase.storage.StorageReference; import com.google.firebase.storage.UploadTask; import com.mianasad.chatsapp.Adapters.MessagesAdapter; import com.mianasad.chatsapp.Models.Message; import com.mianasad.chatsapp.R; import com.mianasad.chatsapp.databinding.ActivityChatBinding; import org.json.JSONObject; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.HashMap; import java.util.Map; public class ChatActivity extends AppCompatActivity { ActivityChatBinding binding; MessagesAdapter adapter; ArrayList<Message> messages; String senderRoom, receiverRoom; FirebaseDatabase database; FirebaseStorage storage; ProgressDialog dialog; String senderUid; String receiverUid; String token; String name; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); binding = ActivityChatBinding.inflate(getLayoutInflater()); setContentView(binding.getRoot()); setSupportActionBar(binding.toolbar); database = FirebaseDatabase.getInstance(); storage = FirebaseStorage.getInstance(); dialog = new ProgressDialog(this); dialog.setMessage("Uploading image..."); dialog.setCancelable(false); messages = new ArrayList<>(); String name = getIntent().getStringExtra("name"); String profile = getIntent().getStringExtra("image"); String token = getIntent().getStringExtra("token"); //Toast.makeText(this, token, Toast.LENGTH_SHORT).show(); binding.name.setText(name); Glide.with(ChatActivity.this).load(profile) .placeholder(R.drawable.avatar) .into(binding.profile); binding.imageView2.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { finish(); } }); receiverUid = getIntent().getStringExtra("uid"); senderUid = FirebaseAuth.getInstance().getUid(); database.getReference().child("presence").child(receiverUid).addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot snapshot) { if(snapshot.exists()) { String status = snapshot.getValue(String.class); if(!status.isEmpty()) { if(status.equals("Offline")) { binding.status.setVisibility(View.GONE); } else { binding.status.setText(status); binding.status.setVisibility(View.VISIBLE); } } } } @Override public void onCancelled(@NonNull DatabaseError error) { } }); senderRoom = senderUid + receiverUid; receiverRoom = receiverUid + senderUid; adapter = new MessagesAdapter(this, messages, senderRoom, receiverRoom); binding.recyclerView.setLayoutManager(new LinearLayoutManager(this)); binding.recyclerView.setAdapter(adapter); database.getReference().child("chats") .child(senderRoom) .child("messages") .addValueEventListener(new ValueEventListener() { @Override public void onDataChange(@NonNull DataSnapshot snapshot) { messages.clear(); for(DataSnapshot snapshot1 : snapshot.getChildren()) { Message message = snapshot1.getValue(Message.class); message.setMessageId(snapshot1.getKey()); messages.add(message); } adapter.notifyDataSetChanged(); } @Override public void onCancelled(@NonNull DatabaseError error) { } }); binding.sendBtn.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { String messageTxt = binding.messageBox.getText().toString(); Date date = new Date(); Message message = new Message(messageTxt, senderUid, date.getTime()); binding.messageBox.setText(""); String randomKey = database.getReference().push().getKey(); HashMap<String, Object> lastMsgObj = new HashMap<>(); lastMsgObj.put("lastMsg", message.getMessage()); lastMsgObj.put("lastMsgTime", date.getTime()); database.getReference().child("chats").child(senderRoom).updateChildren(lastMsgObj); database.getReference().child("chats").child(receiverRoom).updateChildren(lastMsgObj); database.getReference().child("chats") .child(senderRoom) .child("messages") .child(randomKey) .setValue(message).addOnSuccessListener(new OnSuccessListener<Void>() { @Override public void onSuccess(Void aVoid) { database.getReference().child("chats") .child(receiverRoom) .child("messages") .child(randomKey) .setValue(message).addOnSuccessListener(new OnSuccessListener<Void>() { @Override public void onSuccess(Void aVoid) { sendNotification(name, message.getMessage(), token); } }); } }); } }); binding.attachment.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { Intent intent = new Intent(); intent.setAction(Intent.ACTION_GET_CONTENT); intent.setType("image/*"); startActivityForResult(intent, 25); } }); final Handler handler = new Handler(); binding.messageBox.addTextChangedListener(new TextWatcher() { @Override public void beforeTextChanged(CharSequence s, int start, int count, int after) {