Redis Cache Implementation

-

PRE-REQUISITES:-

1.)  Install Redis For Local using Below Link:-

 https://github.com/microsoftarchive/redis/releases/download/win-3.2.100/Redis-x64-3.2.100.msi

2.) Redis access for a particular port in Local:-

i.e, 127.0.0.1:6379

3.) Configure Redis and Start using the service. 


CODE:-

[Route("api/[controller]")]

[ApiController]

public class SearchController : ControllerBase

{

    private readonly ConnectionMultiplexer _redis;

    private readonly IConfiguration _configuration;

    private readonly EmailSettings _emailSettings;

    public SearchController(IConfiguration configuration, IOptions<EmailSettings> emailSettings)

    {

        _redis = ConnectionMultiplexer.Connect(configuration["RedisDb"]);

        _configuration = configuration;

        _emailSettings = emailSettings.Value;

    }



    [HttpPost("get-search-history-by-word")]

    public IActionResult AddNGetToSearchHistory([FromBody]SearchHistoryRequest searchRequest)

    {

        string cacheKey = "SearchHistory";

        IDatabase redisDb = _redis.GetDatabase();

        List<string> searchHistory = SearchLogic.GetSearchHistoryFromRedis(cacheKey, redisDb, searchRequest.maxCounterForWord);

        List<string> filteredSearchHistory = new List<string>();


        foreach (var historyItem in searchHistory)

        {

            string[] parts = historyItem.Split(':');

            string wordPart = parts[0];

            string wordInitials = wordPart.Substring(0, Math.Min(wordPart.Length == 1 ? 1 : wordPart.Length - 1, wordPart.Length));

            if (string.IsNullOrEmpty(searchRequest.word) || wordPart.Length >= searchRequest.word.Length && (searchRequest.word.StartsWith(wordInitials, StringComparison.InvariantCultureIgnoreCase)) || wordPart.Length >= searchRequest.word.Length && (wordInitials.StartsWith(searchRequest.word, StringComparison.InvariantCultureIgnoreCase)))

            {

               filteredSearchHistory.Add(historyItem);

            }

        }


        // Check if the word exists in the Redis cache set

        bool wordExists = redisDb.SetContains(cacheKey, searchRequest.word);

        if (!string.IsNullOrEmpty(searchRequest.word) && !wordExists)

        {

            // Add the new word to the Redis cache set

            redisDb.SetAdd(cacheKey, searchRequest.word);


            // Set the initial counter value for the new word

            string counterKey = $"{cacheKey}:{searchRequest.word}:counter";

            redisDb.StringSet(counterKey, 1);

        }

        else if(wordExists) 

        {

            //Increment the counter for the existing word

            string counterKey = $"{cacheKey}:{searchRequest.word}:counter";

            long counter = redisDb.StringIncrement(counterKey);

        }

        // to fetch 10 words only - use the below code

        return Ok(filteredSearchHistory.Take(10).OrderByDescending(item => SearchLogic.GetCounterValue(item)));


        // to fetch all words- use the below code

        //return Ok(filteredSearchHistory);

    }


    [HttpPost("post-search-history")]

    public IActionResult PostSearchHistory(string word)

    {

        string cacheKey = "SearchHistory";

        IDatabase redisDb = _redis.GetDatabase();


        // Check if the word exists in the Redis cache set

        bool wordExists = redisDb.SetContains(cacheKey, word);


        if (wordExists)

        {

            // Increment the counter for the existing word

            string counterKey = $"{cacheKey}:{word}:counter";

            long counter = redisDb.StringIncrement(counterKey);

        }

        else

        {

            // Add the new word to the Redis cache set

            redisDb.SetAdd(cacheKey, word);


            // Set the initial counter value for the new word

            string counterKey = $"{cacheKey}:{word}:counter";

            redisDb.StringSet(counterKey, 1);

        }


        return Ok("Word added to search history");

    }


    [HttpDelete("clean-search-history")]

    public IActionResult CleanSearchHistory()

    {

        string cacheKey = "SearchHistory";

        IDatabase redisDb = _redis.GetDatabase();


        // Remove the cache key and associated counter keys

        redisDb.KeyDelete(cacheKey);

        RedisValue[] searchedWords = redisDb.SetMembers(cacheKey);

        foreach (var word in searchedWords)

        {

            string counterKey = $"{cacheKey}:{word}:counter";

            redisDb.KeyDelete(counterKey);

        }

        return Ok("Cache has been Cleared");

    }


    [HttpDelete("clean-search-history-by-word")]

    public IActionResult CleanSearchHistory([FromBody] string wordToDelete)

    {

        if (string.IsNullOrEmpty(wordToDelete))

        {

            return BadRequest("Please provide a word to delete.");

        }


        string cacheKey = "SearchHistory";

        IDatabase redisDb = _redis.GetDatabase();


        // Remove the specific word from the cache set

        redisDb.SetRemove(cacheKey, wordToDelete);


        // Remove the associated counter key

        string counterKey = $"{cacheKey}:{wordToDelete}:counter";

        redisDb.KeyDelete(counterKey);


        return Ok($"Word '{wordToDelete}' has been removed from the cache.");

    }

   }

}

Comments

Post a Comment

Popular posts from this blog

Parameter Query

-
If we pass the value with (, ' " ! $) symbols in the control that will not be accepted through normal query. Parameter Query is used to accept the value with special symbols in the control like textbox. Parameter Query use a user defined variable with an @ sign.  In Parameter Query control is written in a different syntax. Column name and variable name can not be the same. Without column_name we can not perform Parameter query. Syntax- Insert- string s= "insert into Table_name (Column_name) values (@variable_name)"; cm = new SqlCommand(s,cn); cm.Parameters.AddWithValue("variable_name", control_name); cm.ExecuteNonQuery(); Update- string q = "update Proc_table set name=@name1 where email = @email1"; cm = new SqlCommand(q, cn); cm.Parameters.AddWithValue("name1", TextBox1.Text); cm.Parameters.AddWithValue("email1", TextBox2.Text); cm.ExecuteNonQuery();  
Read more

Final Project

-
Image
Registration form project   CODING- using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.UI; using System.Web.UI.WebControls; using System.Data.SqlClient; using System.Configuration; public partial class RegPage : System.Web.UI.Page {     SqlConnection cn;     SqlCommand cm;     SqlDataReader dr;     FinalClass fc = new FinalClass();     protected void Page_Load(object sender, EventArgs e)     {         if (!IsPostBack)         {             statedisplay();         }     }     protected void connect()     {         string s = ConfigurationManager.AppSettings["Ch_Db"];         cn = new SqlConnection(s);         cn.Open();          }     protected void statedisplay...
Read more

Grid View Paging

-
  Grid View paging- Grid view paging is used when we have to read the data in bulk then we divide the complete data records into pages consists 10 records in one page. SqlDataAdapter - It is used for Grid View Paging Data Adapter reads data in group of 10 records unlike DataReader which reads the data line by line. DataSet - DataSet Object is created, it accepts the data in bulk. Fill() - Fill() is used. CODE - protected void display() { //Connection Code string s = ConfigurationManager.AppSettings["db"]; cn = new SqlConnection(s); cn.Open(); //DataSet Object DataSet ds = new DataSet(); string s = "select * from Videodb"; //SqlDataAdapter object SqlDataReader adp = new SqlDataAdapter(); adp.Fill(ds); GridView1.DataSoruce = ds; GridView1.DataBind(); } Source code-   <asp:GridView ID="GridView1" runat="server" AutoGenerateColumns="False"              Height="589px" Width="483px" OnPageIndexChanging="click...
Read more